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
  • 相关阅读:
    Java中静态字段和静态方法
    Java抽象方法、抽象类以及接口
    Java单例模式
    java继承
    java构造方法
    java方法
    Java常量与变量
    Java初识
    1
    补码,反码,加减法运算,类型取值范围
  • 原文地址:https://www.cnblogs.com/Soar-Pang/p/7279630.html
Copyright © 2011-2022 走看看