airflow.providers.mysql.transfers.trino_to_mysql

模块内容

类

TrinoToMySqlOperator

将数据从 Trino 移动到 MySQL。
class airflow.providers.mysql.transfers.trino_to_mysql.TrinoToMySqlOperator(*, sql, mysql_table, trino_conn_id='trino_default', mysql_conn_id='mysql_default', mysql_preoperator=None, **kwargs)[源代码]

基类： airflow.models.BaseOperator

将数据从 Trino 移动到 MySQL。

请注意，目前数据在推送到 MySQL 之前会加载到内存中，因此此操作符应仅用于少量数据。

参数

  • sql (str) – 针对 Trino 执行的 SQL 查询。（已模板化）

  • mysql_table (str) – 目标 MySQL 表，使用点表示法来定位特定数据库。（已模板化）

  • mysql_conn_id (str) – 指向 mysql 连接 ID的引用。

  • trino_conn_id (str) – 源 trino 连接

  • mysql_preoperator (str | None) – 在导入之前针对 mysql 运行的 sql 语句，通常用于截断或删除传入的数据，允许任务具有幂等性（运行两次任务不会重复加载数据）。（已模板化）

template_fields: collections.abc.Sequence[str] = ('sql', 'mysql_table', 'mysql_preoperator')[源代码]
template_ext: collections.abc.Sequence[str] = ('.sql',)[源代码]
template_fields_renderers[源代码]
ui_color = '#a0e08c'[源代码]
execute(context)[源代码]

在创建操作符时派生。

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

请参阅 get_template_context 以获取更多上下文。

此条目是否有帮助？