このチュートリアルでは、Cloud Scheduler を使用して、Pub/Sub トピックをターゲットに設定し、Cloud Run のイベント ドリブン関数をトリガーする方法について説明します。Pub/Sub トピックのメッセージや Cloud Storage バケットの変更など、 Google Cloud プロジェクト内のイベントに応答して関数を直接トリガーする場合は、イベント ドリブン関数を使用します。
関数の HTTP エンドポイントをターゲットにして、HTTP 関数の実行スケジュールを設定することもできます。関数で URL エンドポイントを使用し、Webhook などの HTTP リクエストに応答する必要がある場合は、HTTP 関数を使用します。詳細については、Cloud Run 関数のタイプをご覧ください。
Cloud Run 関数の実行のスケジューリングは、Cloud Scheduler の一般的なユースケースです。このチュートリアルの内容は次のとおりです。
- Pub/Sub トピックをサブスクライブする単純な Cloud Run 関数を作成する。
- Pub/Sub トピックにメッセージを公開する Cloud Scheduler ジョブを作成する。
- Cloud Scheduler ジョブを実行する。
- Cloud Run 関数が Cloud Scheduler ジョブによってトリガーされたことを確認する。
Cloud Run のイベント ドリブン関数を作成する
Google Cloud プロジェクト内のイベント(この場合は Pub/Sub トピックに公開されたメッセージ)に応答して直接トリガーされるイベント ドリブン関数を作成します。
Google Cloud コンソールで、[Cloud Run functions] ページに移動します。
[関数を作成] をクリックします。
[基本] セクションで、次の操作を行います。
- [環境] リストで [第 2 世代] を選択します。
- 関数の名前を入力します。
- [リージョン] リストでリージョンを選択します。
[トリガー] セクションで、次の操作を行います。
- [トリガーのタイプ] リストで [Cloud Pub/Sub] を選択します。
- [Cloud Pub/Sub トピック] リストで、既存のトピックを選択するか、[トピックを作成] をクリックして新しいトピックを作成します。後の手順で必要になるため、トピックの名前をメモしておきます。
[その他のオプション] をクリックします。
[Eventarc トリガー] パネルが開きます。
[Eventarc トリガー] パネルで、次の操作を行います。
- ファンクションの呼び出しに必要な ID トークンを Pub/Sub サービスが作成できるようにするよう求められたら、[付与] をクリックします。
- [サービス アカウント] リストで、以前に作成したサービス アカウントを選択します。
- 他の値はデフォルトを使用します。
[トリガーを保存] をクリックします。
[Eventarc トリガー] パネルが閉じます。
その他のデフォルト値はそのままにして、[次へ] をクリックします。
デフォルトのランタイム言語とサンプルコードは変更しないでください。このコードはクラウド サービスを使用せず、追加の権限を有効にする必要もありません。[デプロイ] をクリックします。
Cloud Scheduler ジョブを作成する
Pub/Sub ターゲットを使用して Cloud Scheduler ジョブを作成します。
Google Cloud コンソールで [Cloud Scheduler] ページに移動します。
[ジョブを作成] をクリックします。
ジョブの名前を入力します。
[リージョン] リストでリージョンを選択します。
ジョブの頻度を unix-cron 形式で指定します。
30 16 * * 7
詳細については、cron ジョブの形式とタイムゾーンをご覧ください。
[タイムゾーン] リストで、タイムゾーンを選択します。
[続行] をクリックします。
[ターゲット タイプ] リストで、Pub/Sub を選択します。
先ほど作成した Pub/Sub トピックを選択します。
[メッセージ本文] フィールドに、Pub/Sub ターゲット トピックに送信する文字列を入力します。例: 「Hello world!」
[作成] をクリックします。
日曜日の 16:30 に Pub/Sub トピックにメッセージを送信する cron ジョブが作成されました。Cloud Run 関数は、このトピックにサブスクライブされています。
Cloud Scheduler ジョブを実行する
作成したジョブを実行できるようになりました。
Google Cloud コンソールで、[Cloud Scheduler] ページに移動します。
作成したジョブのチェックボックスをオンにして、[強制実行] をクリックします。
初めて呼び出すときは、プロジェクトで作成された最初のジョブの構成と実行に数分かかることがあります。
ジョブの実行後、[最後の実行のステータス] に
Success
が表示されます。
Cloud Run 関数で結果を確認する
Cloud Run 関数が cron ジョブによって正常にトリガーされ、実行されていることを確認できます。
Google Cloud コンソールで、Cloud Run functions ページに移動します。
ファンクション名をクリックします。
[関数の詳細] ページが開き、[Invocations/Second] グラフに関数の最初の呼び出しが表示されます。
[Logs] タブをクリックします。
Hello, YOUR_STRING!
のようなログエントリが表示されます。