MySQL 到 Google Cloud Storage 運算子¶

Google Cloud Storage (GCS) 服務用於儲存來自各種應用程式的大量資料。本頁說明如何將資料從 MySQL 複製到 GCS。

先決條件任務¶

若要使用這些運算子，您必須完成幾件事

使用 Cloud Console 選取或建立 Cloud Platform 專案。

啟用您專案的計費功能，如 Google Cloud 文件中所述。

啟用 API，如 Cloud Console 文件中所述。
透過 pip 安裝 API 程式庫。
pip install 'apache-airflow[google]'
安裝的詳細資訊請見安裝。
設定 Google Cloud 連線.

MySQLToGCSOperator¶

MySQLToGCSOperator 可讓您將資料從 MySQL 資料庫上傳到 GCS。

當您使用此運算子時，您可以選擇性地將上傳的資料壓縮為 gzip 格式。

以下是使用此運算子上傳資料到 GCS 的範例。

tests/system/google/cloud/gcs/example_mysql_to_gcs.py[原始碼]

    mysql_to_gcs = MySQLToGCSOperator(
        task_id="mysql_to_gcs",
        mysql_conn_id=CONNECTION_ID,
        sql=SQL_SELECT,
        bucket=BUCKET_NAME,
        filename=FILE_NAME,
        export_format="csv",
    )

參考文獻¶

如需更多資訊，請參閱： * MySQL 文件 * Google Cloud Storage 文件