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

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

類¶

`DataformWorkflowInvocationStateSensor`	檢查 Google Cloud Dataform 中 Workflow Invocation 的狀態。
`DataformWorkflowInvocationActionStateSensor`	檢查 Google Cloud Dataform 中 Workflow Invocation Action 的狀態。

模組內容¶

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

Bases: airflow.sensors.base.BaseSensorOperator

檢查 Google Cloud Dataform 中 Workflow Invocation 的狀態。

引數：

project_id (str) – 必需項，要啟動作業的 Google Cloud 專案 ID。如果設定為 None 或缺失，則使用 Google Cloud 連線中的預設 project_id。
region (str) – 必需項，Dataform workflow invocation 的位置（例如 europe-west1）。
repository_id (str) – 必需項。任務所屬的 Dataform 倉庫 ID。
workflow_invocation_id (str) – 必需項，要檢查的 workflow invocation 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 所需的賬號連結串列，該賬號將在請求中被模擬。如果設定為字串，則該賬號必須授予發起賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予 Service Account Token Creator IAM 角色給直接前一個身份，列表中第一個賬號將此角色授予發起賬號（templated）。

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

repository_id[source]¶

workflow_invocation_id[source]¶

expected_statuses[source]¶

failure_statuses = None[source]¶

project_id[source]¶

region[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

hook: airflow.providers.google.cloud.hooks.dataform.DataformHook | None = None[source]¶

poke(context)[source]¶

派生此類時覆蓋。

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

Bases: airflow.sensors.base.BaseSensorOperator

檢查 Google Cloud Dataform 中 Workflow Invocation Action 的狀態。

引數：

project_id (str) – 必需項，要啟動作業的 Google Cloud 專案 ID。如果設定為 None 或缺失，則使用 Google Cloud 連線中的預設 project_id。
region (str) – 必需項，Dataform workflow invocation 的位置（例如 europe-west1）。
repository_id (str) – 必需項。任務所屬的 Dataform 倉庫 ID。
workflow_invocation_id (str) – 必需項，要檢查的 workflow invocation ID。
target_name (str) – 必需項。要在工作流中檢查的目標名稱。
expected_statuses (collections.abc.Iterable[int]) – 操作的預期狀態。請參閱：https://cloud.google.com/python/docs/reference/dataform/latest/google.cloud.dataform_v1beta1.types.WorkflowInvocationAction.State
failure_statuses (collections.abc.Iterable[int]) – 將因異常而終止感測器的狀態
gcp_conn_id (str) – 連線到 Google Cloud 時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑證進行模擬，或獲取列表中最後一個賬號的 access_token 所需的賬號連結串列，該賬號將在請求中被模擬。如果設定為字串，則該賬號必須授予發起賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予 Service Account Token Creator IAM 角色給直接前一個身份，列表中第一個賬號將此角色授予發起賬號（templated）。

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

repository_id[source]¶

workflow_invocation_id[source]¶

project_id[source]¶

region[source]¶

target_name[source]¶

expected_statuses[source]¶

failure_statuses[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

hook: airflow.providers.google.cloud.hooks.dataform.DataformHook | None = None[source]¶

poke(context)[source]¶

派生此類時覆蓋。