airflow.providers.google.cloud.triggers.bigquery_dts

模組內容

類別

BigQueryDataTransferRunTrigger

觸發器類別,用於監看 Transfer Run 狀態以定義任務何時完成。

class airflow.providers.google.cloud.triggers.bigquery_dts.BigQueryDataTransferRunTrigger(project_id, config_id, run_id, poll_interval=10, gcp_conn_id='google_cloud_default', location=None, impersonation_chain=None)[原始碼]

基底類別: airflow.triggers.base.BaseTrigger

觸發器類別,用於監看 Transfer Run 狀態以定義任務何時完成。

參數
  • project_id (str | None) – BigQuery 專案 ID,用於指定傳輸設定的位置

  • config_id (str) – 應監看的 Transfer Run 的設定 ID。

  • run_id (str) – 應監看的 Transfer Run 的 ID。

  • poll_interval (int) – 選擇性參數。定義觸發器檢查任務狀態的頻率間隔。

  • gcp_conn_id (str) – 用於連線至 Google Cloud 的連線 ID。

  • location (str | None) – BigQuery Transfer Service 位置,用於區域性傳輸。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選擇性服務帳戶,用於使用短期憑證模擬身分,或是取得清單中最後一個帳戶的 access_token 所需的帳戶鏈結清單,該帳戶將在請求中被模擬身分。若設定為字串,則該帳戶必須授予發起帳戶「服務帳戶權杖建立者」IAM 角色。若設定為序列,則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分,清單中的第一個帳戶將此角色授予發起帳戶(可使用範本)。

serialize()[原始碼]

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

async run()[原始碼]

如果 Transfer Run 處於終端狀態,則產生 TriggerEvent 物件。

此條目是否有幫助?