从本地文件系统上传数据到 Google Cloud Storage¶

Google Cloud Storage (GCS) 用于存储来自各种应用程序的大量数据。本页展示如何将数据从本地文件系统上传到 GCS。

先决条件任务¶

要使用这些操作符，您必须执行以下几项操作

使用 Cloud Console 选择或创建 Cloud Platform 项目。

按照 Google Cloud 文档中的说明，为您的项目启用结算功能。

按照 Cloud Console 文档中的说明，启用 API。
通过 pip 安装 API 库。
pip install 'apache-airflow[google]'
安装提供了详细信息。
设置 Google Cloud 连接.

LocalFilesystemToGCSOperator¶

LocalFilesystemToGCSOperator 允许您将数据从本地文件系统上传到 GCS。

当您使用此操作符时，您可以选择压缩正在上传的数据。该操作符还支持选择性地以多个块上传数据。

以下是如何使用此操作符将文件上传到 GCS 的示例。

tests/system/google/cloud/gcs/example_gcs_upload_download.py[源代码]

    upload_file = LocalFilesystemToGCSOperator(
        task_id="upload_file",
        src=UPLOAD_FILE_PATH,
        dst=FILE_NAME,
        bucket=BUCKET_NAME,
    )

参考¶

有关更多信息，请查看

Google Cloud Storage 文档