Cloud Composer 1 | Cloud Composer 2
Apache Airflow のプラグイン マネージャーを使用して、カスタムのインハウス Apache Airflow 演算子、フック、センサー、インターフェースを作成できます。詳細については、Airflow ドキュメントのカスタム プラグインをご覧ください。このページでは、Cloud Composer 環境にカスタム プラグインをインストールする方法について説明します。
環境を作成するときに、Cloud Composer によって Cloud Storage バケットが作成され、環境に関連付けられます。カスタム プラグインをインストールするには、関連付けられているバケットの plugins フォルダを使用します。
始める前に
- アカウントには、環境のバケットの内容を表示および変更できるロールが付与されている必要があります。
- ここに示されたインストール方法は、Airflow プラグインにのみ適用されます。たとえば、この方法で一般的な Python モジュールや他のライブラリをインストールすることはできません。
- プラグインは、Airflow プラグイン テンプレートのガイドラインに準拠する必要があります。
プラグインをインストールする
カスタム プラグインを Cloud Composer 環境にインストールするには、プラグインのコードを、Cloud Composer 環境に接続されている Cloud Storage バケットの plugins フォルダにコピーします。
プラグインをインストールするには:
コンソール
Google Cloud Console で [環境] ページに移動します。
使用中の環境を探して、[DAGs] リンクをたどります。
1 つ上のフォルダレベルに移動し、
plugins/フォルダに移動します。プラグイン ファイルをアップロードします。オブジェクトのアップロードの詳細については、オブジェクトのアップロードをご覧ください。
gcloud
次の gcloud コマンドを使用します。
gcloud composer environments storage plugins import \
--environment ENVIRONMENT_NAME \
--location LOCATION \
--source PATH_TO_LOCAL_FILE \
--destination PATH_IN_SUBFOLDER
以下のように置き換えます。
ENVIRONMENT_NAMEを環境の名前にする。LOCATIONは、環境が配置されているリージョン。PATH_TO_LOCAL_FILEは、アップロードするファイルのパスに置き換えます。- （省略可）
PATH_IN_SUBFOLDERは、サブフォルダのパスに置き換えます。pluginsフォルダ内のサブフォルダにプラグインをアップロードするには、--destination引数を使用します。それ以外の場合は、--destination引数を省略します。
プラグインのリストを表示する
コンソール
Google Cloud Console で [環境] ページに移動します。
使用中の環境を探して、[DAGs] リンクをたどります。
1 つ上のフォルダレベルに移動し、
plugins/フォルダに移動します。プラグイン ファイルを表示します。
gcloud
次の gcloud コマンドを使用します。
gcloud composer environments storage plugins list \
--environment ENVIRONMENT_NAME \
--location LOCATION
以下のように置き換えます。
ENVIRONMENT_NAMEを環境の名前にする。LOCATIONは、環境が配置されているリージョン。
プラグインを削除する
Cloud Composer 環境からプラグインを削除するには、環境のバケット内の plugins フォルダからプラグイン コードを削除します。
プラグインを削除するには:
コンソール
gcloud
次の gcloud コマンドを使用します。
gcloud composer environments storage plugins delete \
--environment ENVIRONMENT_NAME \
--location LOCATION \
PLUGIN_TO_DELETE
プラグインをダウンロードする
プラグインをダウンロードするには、次のいずれかの方法を選択してください。
コンソール
Google Cloud Console で [環境] ページに移動します。
使用中の環境を探して、[DAGs] リンクをたどります。
1 つ上のフォルダレベルに移動し、
plugins/フォルダに移動します。プラグイン ファイルをダウンロードします。オブジェクトを削除する方法の詳細については、オブジェクトをダウンロードするをご覧ください。
gcloud
次の gcloud コマンドを使用します。
gcloud composer environments storage plugins export \
--environment ENVIRONMENT_NAME \
--location LOCATION \
--destination PATH_TO_LOCAL_DESTINATION \
--source PATH_IN_FOLDER
以下のように置き換えます。
ENVIRONMENT_NAMEを環境の名前にする。LOCATIONは、環境が配置されているリージョン。PATH_TO_LOCAL_DESTINATIONは、ダウンロードしたファイルの送信先に置き換えます。--sourceは、1 つのプラグインだけをダウンロードするためのオプションです。PATH_IN_FOLDERはフォルダパスです。
プラグインに関するトラブルシューティング
新しくアップロードされたプラグインが Airflow UI に表示されない
Airflow UI アクセス制御を使用すると、新しくアップロードされたプラグインが Airflow UI に表示されないことがあります。この問題を解決するには、新しくアップロードしたプラグインへのアクセスを構成するか、自分自身に Airflow UI で Admin ロールを割り当てるよう Airflow UI 管理者に依頼します。