安裝自訂外掛程式

本頁面說明如何在 Cloud Composer 環境中安裝自訂外掛程式。

您可以在 Cloud Composer 環境中安裝自訂外掛程式,例如自訂內部 Apache Airflow 運算子、掛鉤、感應器或介面。

當您建立環境時,Cloud Composer 會建立 Cloud Storage 值區,並將該值區與您的環境建立關聯。您必須在相關聯值區的 plugins 資料夾中安裝自訂外掛程式。如要確定您的環境連結了哪一個 Cloud Storage 值區,請參閱新增及更新 DAG 一文。

事前準備

  • 以下是在 Cloud Composer 環境的 Cloud Storage 值區中新增和更新外掛程式所需的權限
    • storage.objectAdmin:上傳檔案。
    • composer.environments.get:查詢 DAG 目標值區。使用 Cloud Storage API 或 gsutil 時不需要這項權限。
  • 這個安裝方法僅適用於 Airflow 外掛程式。舉例來說,您無法使用這個方法安裝常用 Python 模組或其他程式庫。

  • 外掛程式必須符合 Airflow 外掛程式範本規範。

安裝外掛程式

如要在 Cloud Composer 環境中安裝自訂外掛程式,請複製外掛程式程式碼,然後在與您 Cloud Composer 環境相連結的 Cloud Storage 值區,將程式碼貼到 plugins 資料夾中。

如要安裝外掛程式,請選擇下列其中一個選項:

gcloud composer environments storage plugins import --environment ENVIRONMENT_NAME \
    --location LOCATION \
    --source PATH_TO_LOCAL_FILE \
    --destination PATH_IN_SUBFOLDER

其中:

  • ENVIRONMENT_NAME 是環境的名稱。
  • LOCATION 是環境所在的 Compute Engine 地區。
  • PATH_TO_LOCAL_FILE 是待上傳檔案的路徑。
  • --destination 可用來將外掛程式上傳到 plugins 資料夾中的子資料夾。PATH_IN_SUBFOLDER 是子資料夾路徑,例如 foo/bar

查看外掛程式清單

如要查看外掛程式清單,請選擇下列其中一個選項:

gcloud composer environments storage plugins list --environment ENVIRONMENT_NAME \
    --location LOCATION

刪除外掛程式

如要將外掛程式從 Cloud Composer 環境中刪除,請在與您 Cloud Composer 環境相連結的 Cloud Storage 值區中,將外掛程式程式碼從 plugins 資料夾中刪除。

如要刪除外掛程式,請選擇下列其中一個選項:

gcloud composer environments storage plugins delete --environment ENVIRONMENT_NAME \
    --location LOCATION PLUGIN_TO_DELETE

下載外掛程式

如要下載外掛程式,請選擇下列其中一個選項:

gcloud composer environments storage plugins export --environment ENVIRONMENT_NAME \
    --location LOCATION \
    --destination PATH_TO_LOCAL_DESTINATION \
    --source PATH_IN_FOLDER

其中:

  • ENVIRONMENT_NAME 是環境的名稱。
  • LOCATION 是環境所在的 Compute Engine 地區。
  • PATH_TO_LOCAL_DESTINATION 是待下載檔案的儲存位置。
  • --source 可用來只下載單一外掛程式。PATH_IN_FOLDER 是資料夾路徑,例如 /foo。

後續步驟

本頁內容對您是否有任何幫助?請提供意見:

傳送您對下列選項的寶貴意見...

這個網頁
Cloud Composer