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

BaseDataMaintenance/dataSource/interface.py

@@ -35,10 +35,8 @@ def getAttachDealInterface(_data,_type,path="",restry=1,kwargs={},url=interface_
             if len(kwargs.keys())>0:
                 _json.update(kwargs)
             headers = {"Content-Type":"application/json"}
-            if session is not None:
+            with requests.Session() as session:
                 _resp = session.post(url,data=_json,timeout=timeout)
-            else:
-                _resp = requests.post(url,data=_json,timeout=timeout)
 
             if _resp.status_code==200:
                 _result = json.loads(_resp.content.decode())

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -92,7 +92,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
         self.conn_mq = getConnect_activateMQ()
         self.pool_mq = ConnectorPool(10,30,getConnect_activateMQ)
 
-        self.session = requests.Session()
+        self.session = None
 
         listener_p = Process(target=self.start_attachment_listener)
         listener_p.start()