airflow.providers.google.cloud.transfers.bigquery_to_mysql¶

此模块包含 Google BigQuery 到 MySQL 的 operator。

类¶

BigQueryToMySqlOperator

从 BigQuery 表中获取数据（或获取选定的列）并将其插入到 MySQL 表中。

模块内容¶

class airflow.providers.google.cloud.transfers.bigquery_to_mysql.BigQueryToMySqlOperator(*, mysql_table=None, target_table_name=None, mysql_conn_id='mysql_default', dataset_id=None, table_id=None, **kwargs)[源码]¶

基类: airflow.providers.google.cloud.transfers.bigquery_to_sql.BigQueryToSqlBaseOperator

从 BigQuery 表中获取数据（或获取选定的列）并将其插入到 MySQL 表中。

另见

有关如何使用此 operator 的更多信息，请参阅指南： Operator

参数:

mysql_table (str | None) – 目标 MySQL 表，使用点表示法指定特定数据库。此参数已弃用：请使用 target_table_name 代替。(templated)
target_table_name (str | None) – 目标 MySQL 表。此参数优先于 mysql_table。(templated)
mysql_conn_id (str) – mysql 连接 ID 的引用。

警告

mysql_table 参数已弃用。请改用 target_table_name。

template_fields: collections.abc.Sequence[str] = ('target_table_name', 'impersonation_chain', 'dataset_id', 'table_id', 'dataset_id', 'table_id')[源码]¶

mysql_conn_id = 'mysql_default'[源码]¶

get_sql_hook()[源码]¶

返回具体的 SQL Hook (例如 PostgresHook)。