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)。