`airflow.providers.google.cloud.transfers.mssql_to_gcs`¶

MsSQL to GCS 運算子。

模組內容¶

類別¶

MSSQLToGCSOperator

以 JSON、CSV 或 Parquet 格式從 Microsoft SQL Server 複製資料到 Google Cloud Storage。

class airflow.providers.google.cloud.transfers.mssql_to_gcs.MSSQLToGCSOperator(*, bit_fields=None, mssql_conn_id='mssql_default', **kwargs)[原始碼]¶

繼承自： airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

以 JSON、CSV 或 Parquet 格式從 Microsoft SQL Server 複製資料到 Google Cloud Storage。

參數

bit_fields (collections.abc.Sequence[str] | None) – MSSQL “BIT” 資料類型欄位名稱的序列，在結構描述中將其解譯為 “BOOLEAN”。未包含在此序列中的 “BIT” 欄位，預設將被解譯為 “INTEGER”。
mssql_conn_id – 參照特定 MSSQL Hook。

範例:

以下運算子將從給定 MSSQL 資料庫中的 Customers 資料表匯出資料，然後將其上傳到 ‘mssql-export’ GCS 儲存桶（以及結構描述檔案）。

export_customers = MSSQLToGCSOperator(
    task_id="export_customers",
    sql="SELECT * FROM dbo.Customers;",
    bit_fields=["some_bit_field", "another_bit_field"],
    bucket="mssql-export",
    filename="data/customers/export.json",
    schema_filename="schemas/export.json",
    mssql_conn_id="mssql_default",
    gcp_conn_id="google_cloud_default",
    dag=dag,
)

參見

如需更多關於如何使用此運算子的資訊，請參閱指南： MSSQLToGCSOperator

ui_color = '#e0a98c'[原始碼]¶

type_map[原始碼]¶

query()[原始碼]¶

查詢 MSSQL 並傳回結果的游標。

返回: mssql 游標

field_to_bigquery(field)[原始碼]¶

將 DBAPI 欄位轉換為 BigQuery 結構描述格式。

classmethod convert_type(value, schema_type, **kwargs)[原始碼]¶

從 MSSQL 取得值，並將其轉換為對 JSON/Google Cloud Storage/BigQuery 安全的值。

Datetime、Date 和 Time 會轉換為 ISO 格式的字串。

airflow.providers.google.cloud.transfers.mssql_to_gcs¶

模組內容¶

類別¶

`airflow.providers.google.cloud.transfers.mssql_to_gcs`¶