airflow.providers.airbyte.operators.airbyte¶
模組內容¶
類別¶
提交任務到 Airbyte 伺服器，以執行來源和目的地之間的整合流程。 |
- class airflow.providers.airbyte.operators.airbyte.AirbyteTriggerSyncOperator(connection_id, airbyte_conn_id='airbyte_default', asynchronous=False, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), api_version='v1', wait_seconds=3, timeout=3600, **kwargs)[原始碼]¶
繼承自:
airflow.models.BaseOperator提交任務到 Airbyte 伺服器，以執行來源和目的地之間的整合流程。
參見
有關如何使用此運算子的更多資訊，請查看指南： AirbyteTriggerSyncOperator
- 參數
airbyte_conn_id (str) – 選填。用於取得 Airbyte 連線資訊的 Airflow 連線名稱。預設為 “airbyte_default”。
connection_id (str) – 必填。來源和目的地之間的 Airbyte ConnectionId UUID。
asynchronous (bool) – 選填。在將任務提交到 Airbyte API 後取得 job_id 的旗標。這對於提交長時間運行的任務並使用 AirbyteJobSensor 非同步等待它們非常有用。預設為 False。
deferrable (bool) – 在可延遲模式下執行運算子。
api_version (str) – 選填。Airbyte API 版本。預設為 “v1”。
wait_seconds (float) – 選填。檢查之間的秒數。僅當
asynchronous為 False 時使用。預設為 3 秒。timeout (float) – 選填。等待請求完成的時間量（秒）。僅當
asynchronous為 False 時使用。預設為 3600 秒（或 1 小時）。
- template_fields: collections.abc.Sequence[str] = ('connection_id',)[原始碼]¶