airflow.providers.amazon.aws.triggers.batch¶
模块内容¶
类¶
检查提交到 AWS Batch 的 job_id 的状态，直到它达到失败或成功状态。 |
|
异步轮询 boto3 API 并等待计算环境准备就绪。 |
- class airflow.providers.amazon.aws.triggers.batch.BatchJobTrigger(job_id, region_name=None, aws_conn_id='aws_default', waiter_delay=5, waiter_max_attempts=720)[源代码]¶
基类:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger检查提交到 AWS Batch 的 job_id 的状态，直到它达到失败或成功状态。
- 参数
job_id (str | None) – 作业 ID，用于轮询作业是否完成。
region_name (str | None) – 要使用的 AWS 区域名称。覆盖连接中的 region_name（如果提供）。
aws_conn_id (str | None) – AWS 凭证/区域名称的连接 ID。如果为 None，则将使用凭据 boto3 策略。
waiter_delay (int) – 检查作业状态的轮询周期（秒）。
waiter_max_attempts (int) – 最大尝试次数。
- class airflow.providers.amazon.aws.triggers.batch.BatchCreateComputeEnvironmentTrigger(compute_env_arn, waiter_delay=30, waiter_max_attempts=10, aws_conn_id='aws_default', region_name=None)[源代码]¶
基类:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger异步轮询 boto3 API 并等待计算环境准备就绪。
- 参数
compute_env_arn (str) – 计算环境的 ARN。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭证的 Airflow 连接。
region_name (str | None) – 在 AWS Hook 中使用的区域名称。
waiter_delay (int) – 尝试之间等待的时间（秒）。