CopyFromExternalStageToSnowflakeOperator¶

使用 CopyFromExternalStageToSnowflakeOperator 將儲存在 AWS S3、Google Cloud Storage 或 Azure Blob Storage 中的資料載入到 Snowflake 表格。

注意

此運算子是 COPY INTO table 查詢的簡單封裝器，並且需要先建立暫存區。

使用運算子¶

與 SnowflakeOperator 類似，使用 snowflake_conn_id 和其他相關參數來建立與您的 Snowflake 實例的連線。此運算子將允許從特定的 Snowflake 暫存區（預先定義的 S3 路徑）載入一個或多個指定名稱的檔案。為了做到這一點，請將相關的檔案名稱傳遞給 files 參數，並將相關的 Snowflake 暫存區傳遞給 stage 參數。pattern 可用於指定檔案名稱和/或路徑匹配模式（請參閱文件）。file_format 可用於參考已存在的 Snowflake 檔案格式或定義檔案格式的自訂字串（請參閱文件）。

以下是 CopyFromExternalStageToSnowflakeOperator 的範例用法

tests/system/snowflake/example_copy_into_snowflake.py[原始碼]

copy_into_table = CopyFromExternalStageToSnowflakeOperator(
    task_id="copy_into_table",
    snowflake_conn_id=SNOWFLAKE_CONN_ID,
    files=[S3_FILE_PATH],
    table=SNOWFLAKE_SAMPLE_TABLE,
    stage=SNOWFLAKE_STAGE,
    file_format="(type = 'CSV',field_delimiter = ';')",
    pattern=".*[.]csv",
)