|
@@ -810,7 +810,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
_url = self.getExtract_url()
|
|
_url = self.getExtract_url()
|
|
log("extract_url:%s"%(str(_url)))
|
|
log("extract_url:%s"%(str(_url)))
|
|
with requests.Session() as session:
|
|
with requests.Session() as session:
|
|
- resp = self.session.post(_url,json=json,headers=headers,timeout=10*60)
|
|
|
|
|
|
+ resp = session.post(_url,json=json,headers=headers,timeout=10*60)
|
|
return resp
|
|
return resp
|
|
|
|
|
|
|
|
|