首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Airflow REST API -如何获取已执行任务的历史记录?

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,有向无环图) 在指定执行实例下的所有任务实例信息。

具体步骤如下:

  1. 使用 GET 请求访问 /api/v1/dags/{dag_id}/dagRuns 接口,获取 DAG 的执行实例列表。
    • {dag_id} 表示目标 DAG 的标识符。
    • 该接口返回执行实例的相关信息,包括执行实例的 ID(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等流行的云计算品牌商。

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

领券