airflow.providers.google.cloud.transfers.bigquery_to_mysql

此模块包含 Google BigQuery 到 MySQL 的操作符。

模块内容

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 表中。

另请参阅

有关如何使用此操作符的更多信息,请参阅指南:操作符

参数
  • mysql_table (str | None) – 目标 MySQL 表,使用点号表示法来指定特定数据库。 它已被弃用:请使用 target_table_name 代替。(已模板化)

  • target_table_name (str | None) – 目标 MySQL 表。 它优先于 mysql_table。(已模板化)

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

警告

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

template_fields: collections.abc.Sequence[str] = ()[源代码]
get_sql_hook()[源代码]

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

此条目是否有帮助?