airflow.providers.amazon.aws.triggers.batch¶

类¶

`BatchJobTrigger`	检查提交给 AWS Batch 的 job_id 的状态，直到达到失败或成功状态。
`BatchCreateComputeEnvironmentTrigger`	异步轮询 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)[source]¶

基类: 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，将使用 credential boto3 策略
waiter_delay (int) – 轮询作业状态的周期（秒）
waiter_max_attempts (int) – 最大尝试次数。

hook()[source]¶

在子类中重写以返回正确的 hook。

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)[source]¶

基类: 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) – 每次尝试之间等待的时间（秒）。

hook()[source]¶

在子类中重写以返回正确的 hook。