Cloud Run ジョブにイベントを公開する

詳細設定

このクイックスタートでは、 Google Cloudプロジェクトで Eventarc Advanced バスを作成して登録し、イベントメッセージをパブリッシュして受信する方法について説明します。

バスは、イベントソースからメッセージを受信したり、プロバイダによって公開されたメッセージを受信したりする中央ルーターとして機能します。
登録は、バスで受信したメッセージを処理パイプラインを介して 1 つ以上の宛先に転送します。

このクイックスタートでは、以下の操作を行います。

ソースコードから Cloud Run ジョブをデプロイします。
Eventarc Advanced バスを作成します。
Eventarc Advanced 登録を作成します。
イベントメッセージをバスにパブリッシュします。
Cloud Run ジョブが正常に実行されたことを確認します。

このクイックスタートでは gcloud CLI を使用します。

始める前に

組織で定義されているセキュリティの制約により、次の手順を完了できない場合があります。トラブルシューティング情報については、制約のある Google Cloud 環境でアプリケーションを開発するをご覧ください。

Google Cloud アカウントにログインします。 Google Cloudを初めて使用する場合は、アカウントを作成して、実際のシナリオでの Google プロダクトのパフォーマンスを評価してください。新規のお客様には、ワークロードの実行、テスト、デプロイができる無料クレジット $300 分を差し上げます。

Google Cloud CLI をインストールします。

外部 ID プロバイダ（IdP）を使用している場合は、まず連携 ID を使用して gcloud CLI にログインする必要があります。

gcloud CLI を初期化するには、次のコマンドを実行します。

gcloud init

Google Cloud プロジェクトを作成または選択します。

プロジェクトの選択または作成に必要なロール

プロジェクトを選択する: プロジェクトの選択に特定の IAM ロールは必要ありません。ロールが付与されているプロジェクトであれば、どのプロジェクトでも選択できます。
プロジェクトを作成する: プロジェクトを作成するには、resourcemanager.projects.create 権限を含むプロジェクト作成者ロール（roles/resourcemanager.projectCreator）が必要です。ロールを付与する方法を確認する。

Google Cloud プロジェクトを作成します。
```
gcloud projects create PROJECT_ID
```
PROJECT_ID は、作成する Google Cloud プロジェクトの名前に置き換えます。
作成した Google Cloud プロジェクトを選択します。
```
gcloud config set project PROJECT_ID
```
PROJECT_ID は、 Google Cloud プロジェクトの名前に置き換えます。

Google Cloud プロジェクトに対して課金が有効になっていることを確認します。

Artifact Registry、Cloud Build、Cloud Run、Eventarc API を有効にします。

API を有効にするために必要なロール

API を有効にするには、serviceusage.services.enable 権限を含む Service Usage 管理者 IAM ロール（roles/serviceusage.serviceUsageAdmin）が必要です。ロールを付与する方法を確認する。

gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com eventarc.googleapis.com eventarcpublishing.googleapis.com run.googleapis.com

Google Cloud CLI をインストールします。

外部 ID プロバイダ（IdP）を使用している場合は、まず連携 ID を使用して gcloud CLI にログインする必要があります。

gcloud CLI を初期化するには、次のコマンドを実行します。

gcloud init

Google Cloud プロジェクトを作成または選択します。

プロジェクトの選択または作成に必要なロール

プロジェクトを選択する: プロジェクトの選択に特定の IAM ロールは必要ありません。ロールが付与されているプロジェクトであれば、どのプロジェクトでも選択できます。
プロジェクトを作成する: プロジェクトを作成するには、resourcemanager.projects.create 権限を含むプロジェクト作成者ロール（roles/resourcemanager.projectCreator）が必要です。ロールを付与する方法を確認する。

Google Cloud プロジェクトを作成します。
```
gcloud projects create PROJECT_ID
```
PROJECT_ID は、作成する Google Cloud プロジェクトの名前に置き換えます。
作成した Google Cloud プロジェクトを選択します。
```
gcloud config set project PROJECT_ID
```
PROJECT_ID は、 Google Cloud プロジェクトの名前に置き換えます。

Google Cloud プロジェクトに対して課金が有効になっていることを確認します。

Artifact Registry、Cloud Build、Cloud Run、Eventarc API を有効にします。

API を有効にするために必要なロール

gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com eventarc.googleapis.com eventarcpublishing.googleapis.com run.googleapis.com

gcloud コンポーネントを更新します。
```
gcloud components update
```

アカウントを使用してログインします。
```
gcloud auth login
```

このクイックスタートで使用する構成変数を設定します。
```
REGION=REGION
```
REGION は、バスでサポートされているロケーション（us-central1 など）に置き換えます。

プロジェクト作成者には、基本オーナーロール（roles/owner）が付与されます。デフォルトでは、この Identity and Access Management（IAM）ロールには、ほとんどの Google Cloudリソースへのフルアクセスに必要な権限が含まれており、この手順は省略できます。

プロジェクト作成者でない場合は、プロジェクトで適切なプリンシパルに必要な権限を付与する必要があります。プリンシパルは Google アカウント（エンドユーザーの場合）やサービスアカウント（アプリケーションとコンピューティングワークロードの場合）になることもあります。
必要な権限

このクイックスタートを完了するために必要な権限を取得するには、プロジェクトに対する次の IAM ロールを付与するよう管理者に依頼してください。
- Cloud Run デベロッパー（roles/run.developer）
- Eventarc デベロッパー（roles/eventarc.developer）
- Eventarc メッセージバス管理者（roles/eventarc.messageBusAdmin）
- ログ表示アクセス者（roles/logging.viewAccessor）
- プロジェクト IAM 管理者（roles/resourcemanager.projectIamAdmin）
- サービスアカウント管理者（roles/iam.serviceAccountAdmin）
- サービスアカウントユーザー（roles/iam.serviceAccountUser）
- Service Usage 管理者（roles/serviceusage.serviceUsageAdmin）
ロールの付与については、プロジェクト、フォルダ、組織へのアクセス権の管理をご覧ください。

必要な権限は、カスタムロールや他の事前定義ロールから取得することもできます。

Eventarc Advanced に Cloud Run ジョブを実行するために必要な権限を付与するには、Google Cloud プロジェクトに対する Cloud Run 呼び出し元（roles/run.invoker）IAM ロールをサービスアカウントに付与するよう管理者に依頼してください。
注: ジョブ構成をオーバーライドするジョブ（メッセージバインディングを定義するなど）を実行するには、Cloud Run デベロッパー（roles/run.developer）または Cloud Run ジョブのオーバーライド付き実行者（roles/run.jobsExecutorWithOverrides）IAM ロールを付与する必要があります。詳細については、特定の実行のジョブ構成をオーバーライドするをご覧ください。
1. サービスアカウントを作成します。テスト目的で、このサービスアカウントを Eventarc Advanced パイプラインに関連付けて、パイプラインの ID を表します。
```
gcloud iam service-accounts create SERVICE_ACCOUNT_NAME
```
  SERVICE_ACCOUNT_NAME をサービスアカウントの名前に置き換えます。
2. サービスアカウントに roles/run.invoker IAM ロールを付与します。
```
gcloud projects add-iam-policy-binding PROJECT_ID \
    --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" \
    --role=roles/run.invoker
```

ソースコードから Cloud Run ジョブをデプロイする

Cloud Run ジョブをイベントの宛先としてデプロイします。リクエストをリッスンして対応する Cloud Run サービスとは異なり、Cloud Run ジョブはタスクを実行するだけで、完了すると終了します。ジョブはリクエストをリッスンすることも対応することもしません。

Pub/Sub トピック、Workflows、別の HTTP エンドポイントなどの他のイベントの宛先もサポートされています。詳細については、イベントプロバイダと宛先をご覧ください。

gcloud run jobs deploy コマンドを使用して、Python ソースコードからジョブを作成します。コードは自動的にコンテナイメージにパッケージ化され、Artifact Registry にアップロードされてから、Cloud Run にデプロイされます。

jobs という名前のディレクトリを作成し、そのディレクトリに移動します。
```
mkdir jobs
cd jobs
```

main.py ファイルを作成し、次のサンプルコードをコピーします。

import os

TASK_INDEX = os.getenv("CLOUD_RUN_TASK_INDEX", 0)

def main():
    """
    This job prints "Hello world"
    """
    print(f"Starting task #{TASK_INDEX}...")
    print("Hello world")
    print(f"Completed task #{TASK_INDEX}.")

# Start script
if __name__ == "__main__":
    main()

ファイル拡張子のない Procfile という名前のテキストファイルを作成し、次のテキストをコピーします。
```
web: python3 main.py
```
ジョブをデプロイします。
```
gcloud run jobs deploy JOB_NAME \
    --source . \
    --tasks 1 \
    --region=$REGION
```
JOB_NAME は、Cloud Run ジョブの一意の名前（my-job など）に置き換えます。

Eventarc Advanced バスを作成する

バスは、メッセージソースからイベントメッセージを受信するか、プロバイダによって公開されたイベントメッセージを受信し、メッセージルーターとして機能します。

詳細については、メッセージを転送するバスを作成するをご覧ください。

gcloud eventarc message-buses create コマンドを使用して、プロジェクトに Eventarc Advanced バスを作成します。

gcloud eventarc message-buses create BUS_NAME \
    --location=$REGION

BUS_NAME は、バスの ID または完全修飾名（my-bus など）に置き換えます。

Eventarc Advanced の登録を作成する

登録により、どのメッセージが宛先に転送されるかが決まります。また、イベントメッセージの宛先を構成するために使用されるパイプラインも指定します。この場合、移行先の宛先は Cloud Run ジョブです。

詳細については、イベントを受信する登録を作成するをご覧ください。

gcloud CLI を使用する場合は、まずパイプラインを作成してから登録を作成します。

gcloud eventarc pipelines create コマンドを使用してパイプラインを作成します。
```
gcloud eventarc pipelines create PIPELINE_NAME \
    --destinations=http_endpoint_uri='JOB_URI',http_endpoint_message_binding_template='{"body": ""}',oauth_token_authentication_service_account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com \
    --input-payload-format-json= \
    --location=$REGION
```
次のように置き換えます。
- PIPELINE_NAME: パイプラインの ID または完全修飾名（例: my-pipeline）。
- JOB_URI: 次の形式の Cloud Run ジョブの URI。
```
https://REGION-run.googleapis.com/apis/run.googleapis.com/v1/namespaces/PROJECT_NUMBER/jobs/JOB_NAME:run
```
  プロジェクト番号を取得するには、次のコマンドを実行します。
```
gcloud projects describe PROJECT_ID --format='value(projectNumber)'
```
次の点にご注意ください。
- http_endpoint_message_binding_template キーは、イベントを Cloud Run Admin API で想定される形式に変換します。メッセージバインディングを定義する場合は、ペイロードにアクセスするための入力形式（{"body": ""} など）を構成する必要があります。
- oauth_token_authentication_service_account キーは、サービスアカウントのメールアドレスを指定します。このメールアドレスは、*.googleapis.com でホストされている Google API を呼び出す場合にのみ使用される OAuth トークンの生成に使用されます。

gcloud eventarc enrollments create コマンドを使用して登録を作成します。

gcloud eventarc enrollments create ENROLLMENT_NAME \
    --cel-match=MATCH_EXPRESSION \
    --destination-pipeline=PIPELINE_NAME \
    --message-bus=BUS_NAME \
    --message-bus-project=PROJECT_ID \
    --location=$REGION

次のように置き換えます。

ENROLLMENT_NAME: 登録の ID または完全修飾名（例: my-enrollment）。
MATCH_EXPRESSION: この登録のCEL を使用した一致式。例:
```
"message.type == 'hello-world-type'"
```

イベントメッセージをバスにパブリッシュする

メッセージをバスに直接パブリッシュするには、gcloud eventarc message-buses publish コマンドを使用するか、Eventarc Publishing REST API にリクエストを送信します。詳細については、イベントを直接パブリッシュするをご覧ください。

メッセージは、イベントデータを一般的な方法で記述するための仕様である CloudEvents 形式である必要があります。data 要素は、イベントのペイロードです。このフィールドには、整形式の JSON を指定できます。CloudEvents コンテキスト属性の詳細については、イベント形式をご覧ください。

次の例は、Eventarc Advanced バスにイベントを直接パブリッシュする例です。

例 1

gcloud CLI と --event-data およびその他のイベント属性フラグを使用して、イベントをバスにパブリッシュします。

gcloud eventarc message-buses publish BUS_NAME \
    --event-data='{"key": "hello-world-data"}' \
    --event-id=hello-world-id-1234 \
    --event-source=hello-world-source \
    --event-type=hello-world-type \
    --event-attributes="datacontenttype=application/json" \
    --location=$REGION

例 2

gcloud CLI と --json-message フラグを使用して、イベントを JSON メッセージとしてバスにパブリッシュします。

gcloud eventarc message-buses publish BUS_NAME \
    --location=$REGION \
    --json-message='{"id": "hello-world-id-1234", "type":
 "hello-world-type", "source":
 "hello-world-source", "specversion": "1.0", "data":
 {"key": "hello-world-data"}}'

イベントを公開すると、「イベントが正常に公開されました」というメッセージが表示されます。

Cloud Run ジョブが正常に実行されたことを確認する

Eventarc Advanced バスにイベントを公開したら、Cloud Run ジョブのログを確認して、Cloud Run ジョブが正常に実行され、「Hello world」が出力されたことを確認します。ジョブが実行されて完了するまでに数分かかることがあります。

gcloud logging read コマンドを使用して、ログエントリをフィルタして出力を返します。
```
gcloud logging read 'textPayload: "Hello world"'
```

次のようなログエントリを探します。

insertId: 693c8dd0000cb2976d7966b8
...
labels:
    job_name: JOB_NAME
    location: REGION
    project_id: PROJECT_ID
type: cloud_run_job
textPayload: Hello world
timestamp: '2025-12-12T21:49:04.832151Z'

gcloud run jobs describe コマンドを使用して、Cloud Run ジョブが正常に実行されたことを確認することもできます。
```
gcloud run jobs describe JOB_NAME \
    --region=$REGION
```
出力は次のようになります。
```
✔ Job JOB_NAME in region us-central1
Executed 1 time
...
```

Eventarc Advanced バスと登録が正常に作成され、イベントメッセージがバスにパブリッシュされ、イベントレシーバのログで期待される結果が確認されました。

クリーンアップ

このクイックスタートの終了後に課金が発生しないようにするには、作成したリソースを削除します。

Cloud Run ジョブを削除します。
Eventarc Advanced リソースを削除します。

また、 Google Cloud プロジェクトを削除して、料金が発生しないようにすることもできます。 Google Cloud プロジェクトを削除すると、そのプロジェクト内で使用されているすべてのリソースに対する課金が停止します。

注意: プロジェクトを削除すると、次のような影響があります。

プロジェクト内のすべてのものが削除されます。既存のプロジェクトを使用してこのドキュメントのタスクを行った場合、そのプロジェクトを削除すると、プロジェクト内で行った他の作業もすべて削除されます。
カスタムプロジェクト ID が失われます。このプロジェクトを作成したときに、将来使用するカスタムプロジェクト ID を作成した可能性があります。そのプロジェクト ID を使用した URL（例: appspot.com）を保持するには、プロジェクト全体ではなく、プロジェクト内の選択したリソースだけを削除します。

複数のアーキテクチャ、チュートリアル、クイックスタートを実施する予定がある場合は、プロジェクトを再利用すると、プロジェクトの割り当て上限を超えないようにすることができます。

Google Cloud プロジェクトを削除します。

gcloud projects delete PROJECT_ID

Cloud Run ジョブにイベントを公開する

始める前に

必要な権限

ソースコードから Cloud Run ジョブをデプロイする

Eventarc Advanced バスを作成する

Eventarc Advanced の登録を作成する

イベント メッセージをバスにパブリッシュする

例 1

例 2

Cloud Run ジョブが正常に実行されたことを確認する

クリーンアップ

次のステップ

イベントメッセージをバスにパブリッシュする