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

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -55,6 +55,7 @@ class DynamicProcess(Process):
         self.comsumer_handler = comsumer_handler
         self.comsumer_count = comsumer_count
         self.queue_name = queue_name
+        super().__init__()
 
     def run(self):