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

基类： 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')[source]
template_ext: collections.abc.Sequence[str] = ('.sql',)[source]
template_fields_renderers[source]
ui_color = '#e07c24'[source]
src_hook()[source]
dest_hook()[source]
execute(context)[source]

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

此条目是否有帮助？