airflow.providers.teradata.transfers.teradata_to_teradata¶

類¶

TeradataToTeradataOperator

將資料從 Teradata 源資料庫移動到 Teradata 目標資料庫。

模組內容¶

class airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator(*, dest_teradata_conn_id, destination_table, source_teradata_conn_id, sql, sql_params=None, rows_chunk=5000, **kwargs)[原始碼]¶

基類: airflow.models.BaseOperator

將資料從 Teradata 源資料庫移動到 Teradata 目標資料庫。

另請參閱

有關如何使用此 operator 的更多資訊，請參閱以下指南：TeradataToTeradataOperator

引數:

dest_teradata_conn_id (str) – 目標 Teradata 連線。
destination_table (str) – 插入行的目標表。
source_teradata_conn_id (str) – 源 Teradata 連線。
sql (str) – 針對源 Teradata 資料庫執行的 SQL 查詢
sql_params (dict | None) – SQL 查詢中使用的引數。
rows_chunk (int) – 每次提交的行塊數。

template_fields: collections.abc.Sequence[str] = ('sql', 'sql_params')[原始碼]¶

template_ext: collections.abc.Sequence[str] = ('.sql',)[原始碼]¶

template_fields_renderers[原始碼]¶

ui_color = '#e07c24'[原始碼]¶

dest_teradata_conn_id[原始碼]¶

destination_table[原始碼]¶

source_teradata_conn_id[原始碼]¶

sql[原始碼]¶

sql_params = None[原始碼]¶

rows_chunk = 5000[原始碼]¶

屬性 src_hook: airflow.providers.teradata.hooks.teradata.TeradataHook[原始碼]¶

屬性 dest_hook: airflow.providers.teradata.hooks.teradata.TeradataHook[原始碼]¶

execute(context)[原始碼]¶

建立 Operator 時派生。

上下文是渲染 Jinja 模板時使用的相同字典。

有關更多上下文資訊，請參閱 get_template_context。