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

模組內容¶

類別¶

`RunJobStatus`	用於表示任務執行狀態的列舉。
`CloudRunJobFinishedTrigger`	Cloud Run 觸發器，用於檢查範本化任務是否已完成。

屬性¶

DEFAULT_BATCH_LOCATION

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

class airflow.providers.google.cloud.triggers.cloud_run.RunJobStatus[原始碼]¶

繼承自： enum.Enum

用於表示任務執行狀態的列舉。

SUCCESS = 'Success'[原始碼]¶

FAIL = 'Fail'[原始碼]¶

TIMEOUT = 'Timeout'[原始碼]¶

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

繼承自： airflow.triggers.base.BaseTrigger

Cloud Run 觸發器，用於檢查範本化任務是否已完成。

參數

operation_name (str) – 必填。操作的名稱。
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()[原始碼]¶

在非同步環境中執行觸發器。

每當觸發器想要觸發事件時，應產生一個 Event，如果已完成，則傳回 None。因此，單一事件觸發器應產生事件，然後立即傳回。

如果它產生事件，則很可能會非常快速地恢復，但也可能不會（例如，如果工作負載正在移動到另一個觸發器程序，或者多事件觸發器正在用於單事件任務延遲）。

在任何情況下，Trigger 類別都應假設它們將被持久化，然後在不再需要它們時依賴呼叫 cleanup()。

airflow.providers.google.cloud.triggers.cloud_run¶

模組內容¶

類別¶

屬性¶

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