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。