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 的连接。