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

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -554,7 +554,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
 
         self.industy_url = "http://127.0.0.1:15000/industry_extract"
 
-        self.extract_interfaces = [["http://127.0.0.1:15030/content_extract",30],
+        self.extract_interfaces = [["http://127.0.0.1:15030/content_extract",20],
                                    ["http://192.168.0.115:15030/content_extract",10]
                                    ]
 
@@ -571,7 +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.comsumer_count = 40
         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()