已弃用的 REST API¶

警告

此 REST API 自 2.0 版本起已弃用。请考虑使用稳定的 REST API。有关迁移的更多信息，请参阅UPDATING.md

警告

请注意，这些 API 端点没有访问控制。经过身份验证的用户具有完全访问权限。

在 Airflow 2.0 之前，此 REST API 被称为“实验性” API，但现在稳定的 REST API可用，它已被重命名。

此 API 的端点位于 /api/experimental/。

在 2.0 版本中更改: 此 REST API 默认禁用。要在迁移到稳定的 REST API 时恢复这些 API，请将 [api] 部分中的 enable_experimental_api 选项设置为 True。

端点¶

POST /api/experimental/dags/<DAG_ID>/dag_runs¶

为给定的 DAG id 创建一个 dag_run。注意：如果在正文中未指定 execution_date，则默认情况下，Airflow 对于给定的 DAG_ID 每秒仅创建一个 DAG。为了在一秒内创建多个 DagRun，您应该将参数 "replace_microseconds" 设置为 "false"（布尔值作为字符串）。

execution_date 必须以 YYYY-mm-DDTHH:MM:SS.ssssss 格式指定。

使用配置触发 DAG，示例

curl -X POST \
    'https://127.0.0.1:8080/api/experimental/dags/<DAG_ID>/dag_runs' \
    --header 'Cache-Control: no-cache' \
    --header 'Content-Type: application/json' \
    --data '{"conf":"{\"key\":\"value\"}"}'

以毫秒精度触发 DAG，示例

curl -X POST  \
    'https://127.0.0.1:8080/api/experimental/dags/<DAG_ID>/dag_runs' \
    --header 'Content-Type: application/json' \
    --header 'Cache-Control: no-cache' \
    --data '{"replace_microseconds":"false"}'

GET /api/experimental/dags/<DAG_ID>/dag_runs¶: 返回特定 DAG ID 的 Dag Run 列表。

GET /api/experimental/dags/<string:dag_id>/dag_runs/<string:execution_date>¶: 返回一个 JSON，其中包含 dag_run 的公共实例变量。<string:execution_date> 的格式应为 YYYY-mm-DDTHH:MM:SS，例如："2016-11-16T11:34:15"。

GET /api/experimental/test¶: 检查 REST API 服务器是否正常工作。返回状态“OK”。

GET /api/experimental/dags/<DAG_ID>/tasks/<TASK_ID>¶: 返回任务的信息。

GET /api/experimental/dags/<DAG_ID>/dag_runs/<string:execution_date>/tasks/<TASK_ID>¶: 返回一个 JSON，其中包含任务实例的公共实例变量。<string:execution_date> 的格式应为 YYYY-mm-DDTHH:MM:SS，例如："2016-11-16T11:34:15"。

GET /api/experimental/dags/<DAG_ID>/paused/<string:paused>¶: “<string:paused>”必须为“true”以暂停 DAG，为“false”以取消暂停。

GET /api/experimental/dags/<DAG_ID>/paused¶: 返回 DAG 的暂停状态

GET /api/experimental/latest_runs¶: 返回为 UI 格式化的每个 DAG 的最新 DagRun。

GET /api/experimental/pools¶: 获取所有池。

GET /api/experimental/pools/<string:name>¶: 按给定名称获取池。

POST /api/experimental/pools¶: 创建池。

DELETE /api/experimental/pools/<string:name>¶: 删除池。

GET /api/experimental/lineage/<DAG_ID>/<string:execution_date>/¶: 返回 DAG 的沿袭信息。