`airflow.providers.google.cloud.sensors.dataform`¶

此模組包含 Google Cloud Dataform 感測器。

模組內容¶

類別¶

`DataformWorkflowInvocationStateSensor`	檢查 Google Cloud Dataform 中工作流程調用狀態。
`DataformWorkflowInvocationActionStateSensor`	檢查 Google Cloud Dataform 中工作流程調用動作狀態。

class airflow.providers.google.cloud.sensors.dataform.DataformWorkflowInvocationStateSensor(*, project_id, region, repository_id, workflow_invocation_id, expected_statuses, failure_statuses=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]¶

基底類別: airflow.sensors.base.BaseSensorOperator

檢查 Google Cloud Dataform 中工作流程調用狀態。

參數

project_id (str) – 必填，要啟動任務的 Google Cloud 專案 ID。如果設定為 None 或遺失，則會使用 Google Cloud 連線中的預設 project_id。
region (str) – 必填，Dataform 工作流程調用的位置 (例如 europe-west1)。
repository_id (str) – 必填。任務所屬的 Dataform 儲存庫 ID。
workflow_invocation_id (str) – 必填，要檢查的工作流程調用 ID。
expected_statuses (set[int] | int) – 運算的預期狀態。請參閱： https://cloud.google.com/python/docs/reference/dataform/latest/google.cloud.dataform_v1beta1.types.WorkflowInvocation.State
failure_statuses (collections.abc.Iterable[int] | None) – 將以例外終止感測器的狀態
gcp_conn_id (str) – 用於連線至 Google Cloud 的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或用於取得清單中最後一個帳戶的 access_token 的鏈結帳戶清單，該帳戶將在請求中被模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊鄰的前一個身分，清單中的第一個帳戶將此角色授予原始帳戶 (可使用範本)。

template_fields: collections.abc.Sequence[str] = ('workflow_invocation_id',)[原始碼]¶

poke(context)[原始碼]¶

在衍生此類別時覆寫。

class airflow.providers.google.cloud.sensors.dataform.DataformWorkflowInvocationActionStateSensor(*, project_id, region, repository_id, workflow_invocation_id, target_name, expected_statuses, failure_statuses, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]¶