使用多线程补采公告

comData/noticeReport/公告补采1.py

-"""
+"""
@@ -273,8 +273,8 @@ def main(page,p,esMethod):
         end_time = time.time()
         elapsed_time = end_time - start_time
         # log.info(f'******更新一条数据耗时{elapsed_time}秒******')
-    cursor_.close()
-    cnx_.close()
+    # cursor_.close()
+    # cnx_.close()
 
 
 def run_threads(num_threads,esMethod):
@@ -291,14 +291,14 @@ def run_threads(num_threads,esMethod):
         thread.join()
 
 if __name__ == '__main__':
-    # while True:
+    while True:
         esMethod = EsMethod()
-    #     p = 0
-    #     result = esMethod.queryatt(index_name=esMethod.index_name, pnum=p)
-    #     total = result['hits']['total']['value']
-    #     if total == 0:
-    #         log.info('++++已没有数据+++++')
-    #         break
+        p = 0
+        result = esMethod.queryatt(index_name=esMethod.index_name, pnum=p)
+        total = result['hits']['total']['value']
+        if total == 0:
+            log.info('++++已没有数据+++++')
+            break
         start = time.time()
         num_threads = 5
         run_threads(num_threads,esMethod)