如何解决无法通过Airflow API触发DAG,但可以通过Curl命令
- 我正在尝试通过python脚本从Airflow API触发DAG。
- DAG从curl命令触发,但在API中不起作用。
import requests
url ='http://localhost:8080/api/experimental/dags/document_validation/dag_runs'
myobj = {''}
x =requests.post(url,data=myobj,headers={"Content-Type": "application/json"})
print(x.text)
我遇到错误
File "run_dag_api.py",line 6,in <module>
`x = requests.post(url,data = myobj)`
File "/…/lib/python3.7/site-packages/requests/api.py",line 119,in post
`return request('post',url,data=data,json=json,**kwargs)`
File "/…/lib/python3.7/site-packages/requests/api.py",line 61,in request
`return session.request(method=method,url=url,**kwargs)`
File "/…/lib/python3.7/site-packages/requests/sessions.py",line 530,in request
`resp = self.send(prep,**send_kwargs)`
File "/…/lib/python3.7/site-packages/requests/sessions.py",line 643,in send
`r = adapter.send(request,**kwargs)`
File "/…/lib/python3.7/site-packages/requests/adapters.py",line 498,in send
`raise ConnectionError(err,request=request)`
requests.exceptions.ConnectionError: ('Connection aborted.',RemoteDisconnected('Remote end closed connection without response'))
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。