`airflow.providers.google.cloud.triggers.cloud_batch`¶

模組內容¶

類別¶

CloudBatchJobFinishedTrigger

Cloud Batch 觸發器，用於檢查範本化的工作是否已完成。

屬性¶

DEFAULT_BATCH_LOCATION

airflow.providers.google.cloud.triggers.cloud_batch.DEFAULT_BATCH_LOCATION = 'us-central1'[原始碼]¶

class airflow.providers.google.cloud.triggers.cloud_batch.CloudBatchJobFinishedTrigger(job_name, project_id, location=DEFAULT_BATCH_LOCATION, gcp_conn_id='google_cloud_default', impersonation_chain=None, polling_period_seconds=10, timeout=None)[原始碼]¶

Bases: airflow.triggers.base.BaseTrigger

Cloud Batch 觸發器，用於檢查範本化的工作是否已完成。

參數

job_name (str) – 必填。工作名稱。
project_id (str | None) – 必填。啟動工作的 Google Cloud 專案 ID。
location (str) – 選填。執行工作的位置。如果設定為 None，則將使用 DEFAULT_BATCH_LOCATION 的值
gcp_conn_id (str) – 用於連線到 Google Cloud 的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填。要使用短期憑證模擬的服務帳戶，或取得列表中最後一個帳戶的 access_token 所需的鏈式帳戶列表，該帳戶將在請求中被模擬。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則列表中的身分必須授予緊鄰的前一個身分「服務帳戶權杖建立者」IAM 角色，列表中的第一個帳戶將此角色授予原始帳戶（已範本化）。
poll_sleep – 輪詢間隔秒數，用於檢查狀態

serialize()[原始碼]¶

序列化類別引數和類別路徑。

async run()[原始碼]¶

取得工作狀態或產生特定事件。

類別的主要迴圈，用於獲取工作狀態並產生特定事件。

如果工作狀態為成功，則產生具有成功狀態的 TriggerEvent；如果工作狀態為失敗，則產生具有錯誤狀態的 TriggerEvent；如果工作正在被刪除，則產生具有已刪除狀態的 TriggerEvent。在任何其他情況下，Trigger 將等待儲存在 self.polling_period_seconds 變數中的指定時間量。

airflow.providers.google.cloud.triggers.cloud_batch¶

模組內容¶

類別¶

屬性¶

`airflow.providers.google.cloud.triggers.cloud_batch`¶