Application Integration でサポートされているコネクタをご覧ください。

Cloud Pub/Sub トリガー

Cloud Pub/Sub トリガーを使用すると、Pub/Sub ミドルウェアのイベントに基づいて統合を実行できます。

このトリガーを使用すると、パブリッシャーが選択したトピックにメッセージを書き込むたびに統合を実行できます。トピックは、インテグレーションと同じ Google Cloud プロジェクトに存在させることも、別の Google Cloud プロジェクトに存在させることもできます。このトリガーを実行すると、パブリッシュされたメッセージが CloudPubSubMessage 出力変数にも書き込まれます。この変数は、要件に応じて、下流のトリガーやタスクで使用できます。

Application Integration と Cloud Pub/Sub トリガーを使用してサンプル統合を作成する方法については、Cloud Pub/Sub トピックをリッスンしてメールを送信するをご覧ください。

始める前に

Cloud Pub/Sub トリガーを構成する前に、Google Cloud プロジェクトで以下の作業を行っていることを確認してください。

このトリガーを作成するユーザーに、プロジェクト IAM 管理者（roles/resourcemanager.projectIamAdmin）を割り当てます。
インテグレーションがある Google Cloud プロジェクトで Pub/Sub API を有効にします。
Pub/Sub トピックが存在することを確認します。新しい Pub/Sub トピックを作成します。
1. Cloud コンソールで、Pub/Sub の [トピック] ページに移動します。
  Pub/Sub トピックページに移動
2. [トピックを作成] をクリックします。
3. [トピック ID] フィールドに、一意のトピック名を入力します。
4. [保存] をクリックします。
注: トリガーを機能させるためにサブスクリプションを作成する必要はありません。統合を公開すると、Application Integration によりトピックのサブスクリプションが自動的に作成されます。Pub/Sub サブスクリプションページですべてのサブスクリプションを確認できます。
Application Integration の 2023 年 12 月 1 日リリース以降、サブスクリプションの料金は Pub/Sub の料金に従って請求されます。既存の Cloud Pub/Sub トリガーのサブスクリプションは、これまでどおり機能し、料金は請求されません。ただし、既存の Cloud Pub/Sub トリガーのトピックを更新すると、更新された Cloud Pub/Sub トリガーに Pub/Sub の課金が適用されます。

IAM ロールを使用したアクセス管理の詳細については、アクセス制御をご覧ください。

プリンシパルにロールを付与する方法については、アクセス権の付与、変更、取り消しをご覧ください。

Cloud Pub/Sub トリガーを追加する

新規または既存の統合に Cloud Pub/Sub トリガーを追加する手順は次のとおりです。

Google Cloud コンソールで [Application Integration] ページに移動します。
Application Integration に移動
ナビゲーションメニューで [統合] をクリックします。
[統合リスト] ページが開き、Google Cloud プロジェクトで使用可能なすべての統合が一覧表示されます。
既存の統合を選択するか、[統合の作成] をクリックして新しい統合を作成します。
新しい統合を作成する場合:
1. [統合の作成] ペインで名前と説明を入力します。
2. 統合のリージョンを選択します。
  注: [リージョン] プルダウンには、Google Cloud プロジェクトにプロビジョニングされたリージョンのみが表示されます。新しいリージョンをプロビジョニングするには、[リージョンを有効にする] をクリックします。詳細については、新しいリージョンを有効にするをご覧ください。
3. 統合用のサービスアカウントを選択します。統合のサービスアカウントの詳細は、統合ツールバーの [統合の概要] ペインでいつでも変更または更新できます。
  注: サービスアカウントを選択するオプションは、選択したリージョンで統合ガバナンスを有効にしている場合にのみ表示されます。
4. [作成] をクリックします。
統合エディタで統合が開きます。
統合エディタのナビゲーションバーで、[トリガー] をクリックして、使用可能なトリガーのリストを表示します。
[Cloud Pub/Sub trigger] 要素をクリックしてデザイナーに配置します。

Cloud Pub/Sub トリガーを構成する

統合エディタで [Cloud Pub/Sub trigger] 要素をクリックしてトリガー構成ペインを表示し、次のタスクを行います。

[Pub/Sub topic] フィールドに、トリガーがリッスンするトピックを次の形式で指定します。
```
projects/PROJECT_ID/topics/TOPIC_ID
```
Google Cloud プロジェクトで使用可能なすべてのトピックを表示するには、[トピック] の [トピックの名前] 列をご覧ください。別の Google Cloud プロジェクトからトピックを選択することもできます。
以下を置き換えます。
- PROJECT_ID: トピックが作成される Google Cloud プロジェクト。
- TOPIC_ID: Pub/Sub トピックの ID。トピックは、インテグレーションと同じ Google Cloud プロジェクトに存在することも、別の Google Cloud プロジェクトに存在することもできます。
統合の呼び出しに使用するサービスアカウントを選択します。インテグレーションで作成した構成変数を選択することもできます。構成変数の値は、SERVICE_ACCOUNT_NAME@project-id.iam.gserviceaccount.com 形式のサービスアカウントのメールアドレスにする必要があります。例: application-integration-invoke@project123.iam.gserviceaccount.com
構成変数の作成方法については、変数の作成をご覧ください。サービスアカウントの作成方法については、サービスアカウントの作成をご覧ください。

構成変数を選択する場合は、構成変数が参照するサービスアカウントに必要なロールを付与する必要があります。ロールを付与する方法の詳細については、必要な IAM ロールをご覧ください。

サービスアカウントがない場合は、[サービスアカウント] リストで [新規作成] をクリックしてサービスアカウントを作成します。

注: Application Integration 2023 年 12 月 1 日リリース以降、Cloud Pub/Sub トリガーを構成するときに、サービスを指定する必要があります。サービスアカウントが関連付けられていない既存の Pub/Sub トリガーは、これまでどおり機能します。ただし、既存の Pub/Sub トリガーを変更する場合は、これらのトリガーを引き続き使用するようにサービスアカウントを構成する必要があります。

デフォルトでは、サブスクリプションの有効期限オプションは never expire に設定されています。有効期限を別の値に設定する場合は、Google Cloud コンソールで Pub/Sub サブスクリプションページに移動し、サブスクリプションを編集します。

サービスアカウントに必要な IAM ロール

サービスアカウントを選択するときに [付与] をクリックすると、さまざまなサービスアカウントに次のロールが自動的に付与されます。

サービスアカウント IAM ロールの付与

サービスアカウント	IAM ロールの付与
Application Integration のデフォルトのサービスアカウント: `service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com`	Pub/Sub 編集者（`roles/pubsub.editor`）サービスアカウントユーザー（`roles/iam.serviceAccountUser`） Pub/Sub トピックの Google Cloud プロジェクトが統合の Google Cloud プロジェクトと異なる場合、デフォルトのサービスアカウントにはトピックの Google Cloud プロジェクトで Pub/Sub 編集者のロールが必要です。
このトリガーに選択したサービスアカウント	Application Integration の起動元（ `roles/integrations.integrationInvoker` ）

Application Integration のデフォルトのサービスアカウント: service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com

Pub/Sub 編集者（roles/pubsub.editor）
サービスアカウントユーザー（roles/iam.serviceAccountUser）

Pub/Sub トピックの Google Cloud プロジェクトが統合の Google Cloud プロジェクトと異なる場合、デフォルトのサービスアカウントにはトピックの Google Cloud プロジェクトで Pub/Sub 編集者のロールが必要です。

このトリガーに選択したサービスアカウント Application Integration の起動元（ roles/integrations.integrationInvoker ）

トリガー出力

各イベントでは、Cloud Pub/Sub トリガーにより、下流のタスクで使用できる CloudPubSubMessage 出力変数が生成されます。変数は JSON 形式で、PubsubMessage 構造です。

考慮事項

Pub/Sub メッセージの最大サイズは 10 MB です。Pub/Sub のすべての制限事項については、Pub/Sub の割り当てと上限をご覧ください。
Pub/Sub がトピックに複数回同じメッセージを書き込む可能性があります。Pub/Sub のこの動作については、At-Least-Once 配信をご覧ください。したがって、メッセージがトピックに複数回書き込まれないように、べき等になるように統合を設計する必要があります。
注: Pub/Sub メッセージは、メッセージヘッダーの message_id フィールドで一意に識別されます。
インテグレーションの公開を停止しても、メッセージの損失を防ぐために Pub/Sub サブスクリプションは削除されません。ただし、インテグレーションの公開済みのバージョンまたはすべてのインテグレーションバージョンを削除すると、Pub/Sub サブスクリプションも削除されます。

インテグレーション用のフィルタを使用してサブスクリプションを作成する

インテグレーションの特定のイベントを処理する Pub/Sub サブスクリプションのフィルタを設定する場合は、次の手順を行います。

Cloud Pub/Sub トリガーが構成されたインテグレーションを公開します。この手順により、インテグレーションプロジェクトにサブスクリプションが作成されます。
Google Cloud コンソールで、[サブスクリプション] ページに移動します。
サブスクリプションに移動
サブスクリプションを開き、サブスクリプション名を含むすべての詳細をコピーします。
既存のサブスクリプションを削除します。
手順 3 でコピーしたサブスクリプション名を含めて、削除したサブスクリプションのすべての詳細を使用して新しいサブスクリプションを作成し、新しいサブスクリプションにフィルタも追加します。
新しく作成したサブスクリプションによって、フィルタされたメッセージとのインテグレーションがトリガーされます。

SLA の免責

Cloud Pub/Sub トリガーは Pub/Sub プロダクトに依存します。この依存関係は Application Integration の外部にあるため、Application Integration サービスレベル契約（SLA）の利用規約は Cloud Pub/Sub トリガーが正常に active 統合の実行を開始した場合にのみ適用されます。

料金

Cloud Pub/Sub トリガーと Salesforce トリガーでは、コネクタを作成する必要はありません。ただし、コネクタタスクを使用して Pub/Sub または Salesforce に接続する場合は、コネクタの使用量に対して課金されます。料金について詳しくは、Application Integration の料金をご覧ください。

割り当てと上限

割り当てと上限については、割り当てと上限をご覧ください。

次のステップ

すべてのタスクとトリガーを確認する。
インテグレーションをテストして公開する方法について学習する。

エラー処理について学習する。
統合の実行ログについて学習する。