airflow.providers.amazon.aws.sensors.step_function¶
类¶
轮询 Step Function 状态机执行直到其达到终止状态;如果任务失败则失败。 |
模块内容¶
- class airflow.providers.amazon.aws.sensors.step_function.StepFunctionExecutionSensor(*, execution_arn, **kwargs)[source]¶
基类:
airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor
[airflow.providers.amazon.aws.hooks.step_function.StepFunctionHook
]轮询 Step Function 状态机执行直到其达到终止状态;如果任务失败则失败。
执行成功完成后,Sensor 会将状态机的输出通过 XCom Push 到 output
另请参阅
有关如何使用此 Sensor 的更多信息,请参阅指南:等待 AWS Step Functions 状态机执行状态
- 参数:
execution_arn (str) – 要检查其状态的 execution_arn
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
- template_fields: collections.abc.Sequence[str][source]¶