airflow.providers.google.cloud.transfers.bigquery_to_mssql¶

此模組包含 Google BigQuery 到 MSSQL 的 operator。

類¶

BigQueryToMsSqlOperator

從 BigQuery 表中提取資料（或者提取選定的列），並將其插入到 MSSQL 表中。

模組內容¶

class airflow.providers.google.cloud.transfers.bigquery_to_mssql.BigQueryToMsSqlOperator(*, source_project_dataset_table, mssql_table=None, target_table_name=None, mssql_conn_id='mssql_default', **kwargs)[source]¶

Bases: airflow.providers.google.cloud.transfers.bigquery_to_sql.BigQueryToSqlBaseOperator

從 BigQuery 表中提取資料（或者提取選定的列），並將其插入到 MSSQL 表中。

另請參閱

有關如何使用此 operator 的更多資訊，請參閱指南：Operator

引數：

source_project_dataset_table (str) – A dotted <project>.<dataset>.<table>：源 BigQuery 表
mssql_table (str | None) – 目標 MsSQL 表。它已棄用：請改用 target_table_name。(templated)
target_table_name (str | None) – 目標 MsSQL 表。它優先於 mssql_table。(templated)
mssql_conn_id (str) – 對特定 mssql hook 的引用

警告

mssql_table 引數已棄用。請改用 target_table_name。

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

operator_extra_links[source]¶

mssql_conn_id = 'mssql_default'[source]¶

source_project_dataset_table[source]¶

get_sql_hook()[source]¶

返回一個具體的 SQL Hook（例如 PostgresHook）。

persist_links(context)[source]¶

持久化到 SQL provider 的連線。