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 目標資料庫。

參見

關於如何使用此運算子的更多資訊，請參閱指南： 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'[原始碼]
src_hook()[原始碼]
dest_hook()[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

Context 是與渲染 jinja 模板時使用的相同字典。

請參考 get_template_context 以獲得更多上下文。

這個條目有幫助嗎？