airflow.providers.google.cloud.sensors.datafusion¶
此模組包含 Google Cloud Data Fusion 感測器。
類¶
檢查 Google Cloud Data Fusion 中管道的狀態。 |
模組內容¶
- 類 airflow.providers.google.cloud.sensors.datafusion.CloudDataFusionPipelineStateSensor(pipeline_name, pipeline_id, expected_statuses, instance_name, location, failure_statuses=None, project_id=PROVIDE_PROJECT_ID, namespace='default', gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]¶
基類:
airflow.sensors.base.BaseSensorOperator檢查 Google Cloud Data Fusion 中管道的狀態。
- 引數:
pipeline_name (str) – 您的管道名稱。
pipeline_id (str) – 您的管道 ID。
expected_statuses (collections.abc.Iterable[str]) – 預期的狀態
failure_statuses (collections.abc.Iterable[str] | None) – 將終止感測器並丟擲異常的狀態
instance_name (str) – 例項的名稱。
location (str) – 處理請求的 Cloud Data Fusion 位置。
project_id (str) – 例項所屬的 Google Cloud 專案 ID。
namespace (str) – 如果您的管道屬於 Basic 版本例項，則名稱空間 ID 始終為 default。如果您的管道屬於 Enterprise 版本例項，則可以建立名稱空間。
gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者為了獲取列表中最後一個賬號的 access_token 而需要的賬號鏈列表，該賬號鏈將在請求中被模擬。如果設定為字串，則該賬號必須授予發起賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須將 Service Account Token Creator IAM 角色授予緊接其前的身份，其中列表中的第一個賬號將此角色授予發起賬號（模板化）。
- template_fields: collections.abc.Sequence[str] = ('pipeline_id',)[原始碼]¶