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

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -960,13 +960,13 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
 
         # 提取listener
         if create_listener:
-            for ii in range(6):
+            for ii in range(2):
                 listener_p = Process(target=self.start_extract_listener,args=(5,self.mq_extract))
                 listener_p.start()
             for ii in range(1):
                 listener_p = Process(target=self.start_extract_listener,args=(5,self.mq_extract_fix))
                 listener_p.start()
-            for ii in range(4):
+            for ii in range(1):
                 listener_p = Process(target=self.start_extract_listener,args=(5,self.mq_extract_his))
                 listener_p.start()
             listener_p = Process(target=dynamic_listener,args=(["dataflow_extract","dataflow_extract_fix","dataflow_extract_his"],8,self.ExtractListener,lambda comsumer_count,queue_name:self.start_extract_listener(comsumer_count,queue_name),5))