要素提取补充AI提取

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -846,9 +846,9 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
 
         # 提取listener
         if create_listener:
-            # for ii in range(10):
-            #     listener_p = Process(target=self.start_extract_listener)
-            #     listener_p.start()
+            for ii in range(10):
+                listener_p = Process(target=self.start_extract_listener)
+                listener_p.start()
             listener_p_ai = Thread(target=self.start_extract_AI_listener)
             listener_p_ai.start()