airflow.providers.mysql.transfers.vertica_to_mysql

VerticaToMySqlOperator

将数据从 Vertica 移动到 MySQL。

模块内容

class airflow.providers.mysql.transfers.vertica_to_mysql.VerticaToMySqlOperator(sql, mysql_table, vertica_conn_id='vertica_default', mysql_conn_id='mysql_default', mysql_preoperator=None, mysql_postoperator=None, bulk_load=False, *args, **kwargs)[source]

Bases: airflow.models.BaseOperator

将数据从 Vertica 移动到 MySQL。

参数:
  • sql (str) – 要针对 Vertica 数据库执行的 SQL 查询。(模板化)

  • vertica_conn_id (str) – 源 Vertica 连接

  • mysql_table (str) – 目标 MySQL 表,使用点表示法指定特定数据库。(模板化)

  • mysql_conn_id (str) – 引用 mysql 连接 ID

  • mysql_preoperator (str | None) – 在导入前针对 MySQL 运行的 sql 语句,通常用于截断或删除即将导入的数据,使任务具有幂等性(运行两次任务不会重复加载数据)。(模板化)

  • mysql_postoperator (str | None) – 在导入后针对 MySQL 运行的 sql 语句,通常用于将数据从暂存区移动到生产环境并发出清理命令。(模板化)

  • bulk_load (bool) – 使用 bulk_load 选项的标志。这使用 LOAD DATA LOCAL INFILE 命令直接从制表符分隔的文本文件加载到 MySQL。MySQL 服务器必须支持通过此命令加载本地文件(默认情况下禁用)。

template_fields: collections.abc.Sequence[str] = ('sql', 'mysql_table', 'mysql_preoperator', 'mysql_postoperator')[source]
template_ext: collections.abc.Sequence[str] = ('.sql',)[source]
template_fields_renderers[source]
ui_color = '#a0e08c'[source]
sql[source]
mysql_table[source]
mysql_conn_id = 'mysql_default'[source]
mysql_preoperator = None[source]
mysql_postoperator = None[source]
vertica_conn_id = 'vertica_default'[source]
bulk_load = False[source]
execute(context)[source]

创建操作符时派生。

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

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

此条目是否有帮助?