修复附件识别和要素提取消费不足问题,项目合并标段问题解决

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -752,7 +752,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
         self.pool_mq = ConnectorPool(10,30,getConnect_activateMQ)
         self.block_url = RLock()
         self.url_count = 0
-        self.session = requests.Session()
+        self.session = None
 
 
         self.list_extract_comsumer = []
@@ -809,7 +809,8 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
         # _url = self.extract_interfaces[_i]
         _url = self.getExtract_url()
         log("extract_url:%s"%(str(_url)))
-        resp = self.session.post(_url,json=json,headers=headers,timeout=10*60)
+        with requests.Session() as session:
+            resp = self.session.post(_url,json=json,headers=headers,timeout=10*60)
         return resp