Airflow REST API 是 Airflow 任务调度系统提供的一种通过 HTTP 请求与系统交互的方式。通过 Airflow REST API,可以获取已执行任务的历史记录。
要获取已执行任务的历史记录,可以使用 Airflow REST API 提供的 /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances
接口。这个接口可以返回指定 DAG(Directed Acyclic Graph,有向无环图) 在指定执行实例下的所有任务实例信息。
具体步骤如下:
/api/v1/dags/{dag_id}/dagRuns
接口,获取 DAG 的执行实例列表。{dag_id}
表示目标 DAG 的标识符。dag_run_id
)。dag_run_id
),使用 GET 请求访问 /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances
接口,获取该执行实例下的任务实例信息。{dag_id}
表示目标 DAG 的标识符。{dag_run_id}
表示目标执行实例的标识符。通过以上步骤,可以获取到已执行任务的历史记录。
Airflow 是一个开源的任务调度平台,适用于构建和调度复杂的工作流。它提供了丰富的功能和扩展性,使得用户可以方便地管理和监控任务的执行。Airflow REST API 提供了与 Airflow 系统进行交互的方式,用户可以通过编程方式查询和控制任务的执行。
腾讯云推出的产品中,与 Airflow 相关的服务为腾讯云数据工作流(Tencent Cloud Data Workflow,CDW)。CDW 提供了托管的 Airflow 服务,可以在腾讯云上快速部署和管理 Airflow 任务。通过 CDW,用户可以使用 Airflow REST API 进行任务的查询和操作。
了解更多关于腾讯云数据工作流(CDW)的信息,请访问:腾讯云数据工作流(CDW)产品介绍
注意:本回答中没有提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等流行的云计算品牌商。
领取专属 10元无门槛券
手把手带您无忧上云