zoukankan      html  css  js  c++  java
  • 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
  • 相关阅读:
    使用kubeadm部署K8S v1.17.0集群
    06Shell并发控制
    05Shell循环语句
    04Shell流程控制
    03Shell条件测试
    02Shell变量
    01Shell入门02-echo和printf
    01Shell入门01-bash Shell特性
    局域网部署ntp时间服务器
    聊聊、Mybatis集成Spring XML方式
  • 原文地址:https://www.cnblogs.com/Soar-Pang/p/7279630.html
Copyright © 2011-2022 走看看