20170803 Airflow自带的API进行GET 和POST动作部分内容

--1 首先你要有安装好的Airflow 环境并且在配置文件中有启用API 属性

--2 就是GET 和POST 方法的调用了

这里说一下,由于Airflow在网络上的资料比较少,可以从GETHUB中把源码下载下来,使用VSCODE工具进行文件打开,可以进行py文件跳转

--3 测试GET方法

访问路径:http://10.19.52.79:8080/api/experimental/test

杠线部分根据实际发布情况IP 填写(执行可以返回json语句)

--4 测试POST方法

POST方法执行的作用是为了触发DAG,以DAG为最小单位

并且需要POST  一个json 数据

例如地址:http://10.19.52.79:8080/api/experimental/dags/upload_python_operator/dag_runs

其中橙色部分,为指定的DAG包。

POST 触发的Pyhon代码如下:

 

查看源码逻辑,在触发POST 方法后, 代码如下会触发内容:

  dr = trigger.trigger_dag(dag_id, run_id, conf, execution_date)
 

 在vscode 工具中,可以进行代码跳转定义。

 但是在此py最后执行的方法中是没有具体定义的,可能原因为不公开部分

也许并不是你需要的内容,这只是我人生的一些痕迹. -- soar.pang
原文地址:https://www.cnblogs.com/Soar-Pang/p/7279630.html