消息队列分级并设置动态消费者

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -1010,8 +1010,8 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
                 listener_p.start()
             # listener_p = Process(target=dynamic_listener,args=(["dataflow_extract","dataflow_extract_fix","dataflow_extract_his"],8,self.ExtractListener,lambda _dict,result_queue:self.comsumer_handle(_dict,result_queue),2))
             # listener_p.start()
-            # listener_p_ai = Thread(target=self.start_extract_AI_listener)
-            # listener_p_ai.start()
+            listener_p_ai = Thread(target=self.start_extract_AI_listener)
+            listener_p_ai.start()
             pass