airflow.providers.airbyte.operators.airbyte¶

類¶

AirbyteTriggerSyncOperator

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

基類： 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',)[source]¶

ui_color = '#6C51FD'[source]¶

airbyte_conn_id = 'airbyte_default'[source]¶

connection_id[source]¶

timeout = 3600[source]¶

api_version = 'v1'[source]¶

wait_seconds : float = 3[source]¶

asynchronous : bool = False[source]¶

deferrable : bool = True[source]¶

execute(context)[source]¶

建立 Airbyte 作業並等待完成。

execute_complete(context, event=None)[source]¶

觸發器觸發時呼叫此回撥；立即返回。

依賴觸發器丟擲異常，否則假定執行成功。

on_kill()[source]¶: 如果任務被取消，則取消作業。