airflow-api 插件的安装与使用介绍 (2)

GET - {HOST}:{PORT}/admin/rest_api/api?api=list_dags

参数: 1)subdir:可选参数 2)report:可选参数,布尔型,显示dagbag的加载报告 2.16 启动kerberos票证续订

GET - {HOST}:{PORT}/admin/rest_api/api?api=kerberos

参数(均为可选参数): 1)principal 2)keytab 3)pid:pid文件位置 4)daemon:布尔值,是否为守护进程 5)stdout:将stdout重定向到文件 6)stderr:将错误重定向到文件 7)log-file:日志文件 2.17 启动celery工作节点(worker)

GET - {HOST}:{PORT}/admin/rest_api/api?api=worker

参数(均为可选参数): 1)do_pickle:布尔型,尝试picklg DAG对象发送给worker,而不是让worker运行他们的代码版本 2)queues:逗号分隔的队列列表 3)concurrency:工作进程数 4)pid:pid文件位置 5)daemon:布尔值,是否为守护进程 6)stdout:将stdout重定向到文件 7)stderr:将错误重定向到文件 8)log-file:日志文件 2.18 启动celery工作节点(flower)

GET - {HOST}:{PORT}/admin/rest_api/api?api=flower

参数(均为可选参数): 1)hostname:设置运行服务器的主机名 2)port:运行服务器的端口 3)flower_conf:flower的配置文件 4)broker_api 5)pid:pid文件位置 6)daemon:布尔值,是否为守护进程 7)stdout:将stdout重定向到文件 8)stderr:将错误重定向到文件 9)log-file:日志文件 2.19 启动调度程序实例

GET - {HOST}:{PORT}/admin/rest_api/api?api=scheduler

参数(均为可选参数): 1)dag_id 2)subdir:可选参数,从中查找dag的文件位置或者目录 3)run-duration:设置退出前执行的秒数 4)num_runs:设置退出前执行的次数 5)do_pickle:布尔型,尝试pickle DAG对象发送给worker,而不是让worker运行他们的代码版本 6)pid:pid文件位置 7)daemon:布尔值,是否为守护进程 8)stdout:将stdout重定向到文件 9)stderr:将错误重定向到文件 10)log-file:日志文件 2.20 获取task的运行状态

GET - {HOST}:{PORT}/admin/rest_api/api?api=task_state

参数: 1)dag_id 2)task_id 3)execution_date 4)subdir:可选 2.21 CRUD 对pool的操作

GET - {HOST}:{PORT}/admin/rest_api/api?api=pool

参数: 1)set:分别设置池插槽计数和描述。 表单中的预期输入:NAME SLOT_COUNT POOL_DESCRIPTION 2)get:获取池信息 3)delete:删除池 2.22 由worker生成的日志

GET - {HOST}:{PORT}/admin/rest_api/api?api=serve_logs

参数:无

2.23 清除一组任务实例

GET - {HOST}:{PORT}/admin/rest_api/api?api=clear

参数: 1)dag_id 2)task_regex:可选参数,用于过滤特定的task_ids以进行回填正则表达式 3)start_date:覆盖start_date YYYY-MM-DD 4)end_date:可选参数,同上覆盖 5)subdir:可选参数 6)upstream:可选,布尔型,包含上游任务 7)downstream:可选,布尔型,包含下游任务 8)no_confirm:可选,布尔型,不要求确认 9)only_failed:可选,布尔型,仅失败的作业 10)only_running:可选,布尔型,仅运行的作业 11)exclude_subdags:可选,布尔型,排除子标记 2.24 发布一个新的dag

POST - {HOST}:{PORT}/admin/rest_api/api?api=deploy_dag

post参数: 1)dag_file:file-上传部署的py文件 2)force:可选,布尔型,文件已存在,是否强制上传 3)pause:可选,布尔型,在创建时强制暂停dag并覆盖'dags_are_paused_at_creation'配置 4)unpause(可选) - 布尔值 - DAG在创建时将被强制取消暂停,并覆盖'dags_are_paused_at_creation'配置 2.25 刷新一个dag

GET - {HOST}:{PORT}/admin/rest_api/api?api=refresh_dag

参数: 1)dag_id 3. api响应参数: airflow_cmd - 字符串 - 在本地计算机上运行Airflow CLI命令 arguments - Dict - 包含您传入的参数的字典及其值 post_arguments - Dict - 包含您传入的帖子身体参数及其值的字典 call_time - 时间戳 - 服务器接收请求的时间 output - String - 调用CLI函数的文本输出 response_time - 时间戳 - 服务器发回响应的时间 status - 字符串 - 响应呼叫的状态。 (可能的值:OK,ERROR) warning - String - 从API发回的警告消息 http_response_code - 整数 - HTTP响应代码

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpgpwd.html