修改启动时消费者报没有属性的问题

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -571,6 +571,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
             current_weight += self.extract_interfaces[_i][1]
             self.extract_interfaces[_i][1] = current_weight/self.whole_weight
 
+        self.comsumer_count = 45
         self.pool_postgres = ConnectorPool(10,self.comsumer_count,getConnection_postgres)
         self.pool_redis_doc = ConnectorPool(10,self.comsumer_count,getConnect_redis_doc)
         self.conn_mq = getConnect_activateMQ()
@@ -578,7 +579,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
         self.block_url = RLock()
         self.url_count = 0
 
-        self.comsumer_count = 45
+
         self.list_extract_comsumer = []
         for _i in range(self.comsumer_count):
             listener_extract = self.ExtractListener(getConnect_activateMQ(),self.comsumer_handle)