airflow.providers.mysql.transfers.vertica_to_mysql¶
模块内容¶
类¶
将数据从 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)[源代码]¶
基类：
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')[源代码]¶
- template_ext: collections.abc.Sequence[str] = ('.sql',)[源代码]¶