--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最后执行的方法中是没有具体定义的,可能原因为不公开部分