SFTP 到 Azure Blob Storage 傳輸運算子¶

Blob 服務將文字和二進位制資料作為物件儲存在雲端。Blob 服務提供以下三種資源：儲存賬戶、容器和 blob。在您的儲存賬戶中，容器提供了一種組織 blob 集的方式。有關該服務的更多資訊，請訪問 Azure Blob Storage API 文件。

開始之前¶

在 Airflow 中使用 Blob Storage 之前，您需要使用 Token、登入名和密碼來驗證您的賬戶。請按照 Azure 說明進行操作。

請參閱以下示例。為這些欄位設定值

SFTP Conn Id: sftp_default
WASB Conn Id: wasb_default

將資料從 SFTP 源路徑傳輸到 Blob Storage¶

該運算子將資料從 SFTP 源路徑傳輸到 Azure Blob Storage 中指定的容器

要獲取 Azure Blob Storage 中作業的資訊，請使用：SFTPToWasbOperator 示例用法

tests/system/microsoft/azure/example_sftp_to_wasb.py

transfer_files_to_azure = SFTPToWasbOperator(
    task_id="transfer_files_from_sftp_to_wasb",
    # SFTP args
    sftp_source_path=SFTP_SRC_PATH,
    # AZURE args
    container_name=AZURE_CONTAINER_NAME,
    blob_prefix=BLOB_PREFIX,
)