es操做

comData/YanBao/deletebyid.py

@@ -24,7 +24,7 @@ cursor_ = cnx_.cursor()
 lock = threading.Lock()
 
 
-pool = redis.ConnectionPool(host="114.115.236.206", port=6379, password='clbzzsn', db=6)
+pool = redis.ConnectionPool(host="114.116.90.53", port=6380, password='clbzzsn', db=6)
 
 class EsMethod(object):
 
@@ -47,10 +47,10 @@ if __name__ == "__main__":
     redis_conn = redis.Redis(connection_pool=pool)
     while True:
         # 从redis中读取数据，去附件表中根据title查询，更新查到的附件id
-        item = redis_conn.lpop('91330000747735638J:id')
+        item = redis_conn.lpop('NianbaoOT:id')
         if item:
             log.info(item)
-            id = int(item.decode().split('|')[0])
+            id = int(item.decode())
             try:
                 esMethod.delete(esMethod.index_name,id)
             except Exception as e:

comData/YanBao/get_doc_id.py

@@ -26,7 +26,7 @@ lock = threading.Lock()
 pathType = 'QYNotice/'
 taskType = '企业研报/东方财富网'
 
-pool = redis.ConnectionPool(host="114.115.236.206", port=6379, password='clbzzsn', db=6)
+pool = redis.ConnectionPool(host="114.116.90.53", port=6380, password='clbzzsn', db=6)
 
 class EsMethod(object):