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。(已套用 Jinja 模板)

  • target_table_name (str | None) – 目標 MySQL 表格。此參數優先於 mysql_table。(已套用 Jinja 模板)

  • mysql_conn_id (str) – 參考 mysql 連線 ID

警告

mysql_table 參數已被棄用。請改用 target_table_name

template_fields: collections.abc.Sequence[str] = ()[原始碼]
get_sql_hook()[原始碼]

返回一個具體的 SQL Hook(例如 PostgresHook)。

這個條目對您有幫助嗎?