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。