airflow.providers.amazon.aws.operators.mwaa

此模块包含 AWS MWAA operators。

MwaaTriggerDagRunOperator

在 Amazon MWAA 环境中触发 Dag Run。

模块内容

class airflow.providers.amazon.aws.operators.mwaa.MwaaTriggerDagRunOperator(*, env_name, trigger_dag_id, trigger_run_id=None, logical_date=None, data_interval_start=None, data_interval_end=None, conf=None, note=None, wait_for_completion=False, waiter_delay=60, waiter_max_attempts=20, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源码]

基类:airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.mwaa.MwaaHook]

在 Amazon MWAA 环境中触发 Dag Run。

另请参阅

有关如何使用此 operator 的更多信息,请参阅指南: 在 Amazon MWAA 环境中触发 DAG 运行

参数
  • env_name (str) – MWAA 环境名称 (templated)

  • trigger_dag_id (str) – 要触发的 DAG ID (templated)

  • trigger_run_id (str | None) – 运行 ID。此参数与 trigger_dag_id 一起构成唯一键。(templated)

  • logical_date (str | None) – 逻辑日期(之前称为执行日期)。这是此 DAG 运行涵盖的时间或间隔,取决于 DAG 定义。此参数与 trigger_dag_id 一起构成唯一键。(templated)

  • data_interval_start (str | None) – DAG 运行涵盖的时间间隔的开始

  • data_interval_end (str | None) – DAG 运行涵盖的时间间隔的结束

  • conf (dict | None) – 附加配置参数。此字段的值只能在创建对象时设置。(templated)

  • note (str | None) – 包含用户关于 DagRun 手动输入的备注。(templated)

  • wait_for_completion (bool) – 是否等待 DAG 运行停止。(默认值:False)

  • waiter_delay (int) – 状态检查之间的等待时间,单位为秒。(默认值:120)

  • waiter_max_attempts (int) – 检查 DAG 运行完成的最大尝试次数。(默认值:720)

  • deferrable (bool) – 如果为 True,则 operator 将异步等待 DAG 运行停止。这意味着等待完成。此模式需要安装 aiobotocore 模块。(默认值:False)

  • aws_conn_id – 用于 AWS 凭据的 Airflow 连接。如果此参数为 None 或为空,则使用默认的 boto3 行为。如果在分布式环境中运行 Airflow 且 aws_conn_id 为 None 或为空,则将使用默认的 boto3 配置(并且必须在每个 worker 节点上维护)。

  • region_name – AWS region_name。如果未指定,则使用默认的 boto3 行为。

  • verify – 是否验证 SSL 证书。参见: https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html

  • botocore_config – botocore 客户端的配置字典(键值对)。参见: https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[源码]
template_fields: collections.abc.Sequence[str][源码]
template_fields_renderers[源码]
env_name[源码]
trigger_dag_id[源码]
trigger_run_id = None[源码]
logical_date = None[源码]
data_interval_start = None[源码]
data_interval_end = None[源码]
conf[源码]
note = None[源码]
wait_for_completion = False[源码]
waiter_delay = 60[源码]
waiter_max_attempts = 20[源码]
deferrable[源码]
execute_complete(context, event=None)[源码]
execute(context)[源码]

在 Amazon MWAA 环境中触发 Dag Run。

参数

context (airflow.utils.context.Context) – Context 对象

返回值

包含 Dag 运行信息的 dict。有关返回 dict 的详细信息,请参见 botocore.client.MWAA.invoke_rest_api()

返回类型

dict

此条目有帮助吗?