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

基类: 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')[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]¶

trino_conn_id = 'trino_default'[source]¶

execute(context)[source]¶

创建算子时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

有关更多 context 信息，请参考 get_template_context。