airflow中通过代码调度任务

2020年3月4日 09:48 by wst

---

由于需要在一个接口服务中，调度airflow上的任务。所以需要通过代码的方式调度，从而实现自动化。

通过查询airflow的文档，是可以通过api 的方式调度的。实例如下：

import requests
url="http://airflow.xxx.cn/api/experimental/dags/nyg_join_post_mediation/dag_runs"
auth = ("airflow", "xxx123")
headers = {'Cache-Control':'no-cache','Content-Type':'application/json'}
data={'owner':'nyg'}
res = requests.post(url, headers=headers,json=data, auth=auth)
print(res.json())

代码解释：

第二行，找到接口地址。

第三行，用于认证，否则调用无法成功。

第四行，设置头信息。

第五行，设置json信息，即调用时的参数。

第六行，调用

第七行，查看响应信息。

---