Google 會運用 AI 技術將內容翻譯成你偏好的語言，但可能會出錯。

搭配 Cloud Run 使用 Pub/Sub 教學課程

本教學課程說明如何編寫及部署 Cloud Run 服務，並透過 Pub/Sub 推送訂閱項目呼叫這類服務。

目標

編寫、建構服務並部署至 Cloud Run
將訊息發布至 Pub/Sub 主題，藉此呼叫服務。

費用

在本文件中，您會使用下列 Google Cloud計費元件：

您可以使用 Pricing Calculator，根據預測用量估算費用。

初次使用 Google Cloud 的使用者可能符合免費試用期資格。

事前準備

登入 Google Cloud 帳戶。如果您未曾使用過 Google Cloud，歡迎建立帳戶，親自體驗實際使用我們產品的成效。新客戶還能獲得價值 $300 美元的免費抵免額，用於執行、測試及部署工作負載。

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Roles required to select or create a project

Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Go to project selector

Verify that billing is enabled for your Google Cloud project.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Roles required to select or create a project

Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Go to project selector

Verify that billing is enabled for your Google Cloud project.

啟用 Artifact Registry、Cloud Build、Pub/Sub 和 Cloud Run API (如有尚未啟用的 API)。
啟用 API 所需的角色
您必須具備 serviceusage.services.enable 權限，才能啟用 API。如果您建立了專案，可能已透過「擁有者」角色 (roles/owner) 取得這項權限。否則，您可以透過「Service Usage 管理員」角色 (roles/serviceusage.serviceUsageAdmin) 取得這項權限。瞭解如何授予角色。
啟用 API

安裝並初始化 gcloud CLI。
更新元件：
```
gcloud components update
```

必要的角色

如要取得完成教學課程所需的權限，請要求管理員在專案中授予您下列 IAM 角色：

Cloud Build 編輯者 (roles/cloudbuild.builds.editor)
Cloud Run 管理員 (roles/run.admin)
建立服務帳戶 (roles/iam.serviceAccountCreator)
專案 IAM 管理員 (roles/resourcemanager.projectIamAdmin)
Pub/Sub 編輯者 (roles/pubsub.editor)
服務帳戶使用者 (roles/iam.serviceAccountUser)
服務使用情形消費者 (roles/serviceusage.serviceUsageConsumer)
儲存空間管理員 (roles/storage.admin)

如要進一步瞭解如何授予角色，請參閱「管理專案、資料夾和組織的存取權」。

您或許也能透過自訂角色或其他預先定義的角色，取得必要權限。

設定 gcloud 預設值

如要針對 Cloud Run 服務設定 gcloud 的預設值：

設定您的預設專案：
```
gcloud config set project PROJECT_ID
```
將 PROJECT_ID 替換為您為本教學課程建立的專案名稱。
為所選區域設定 gcloud：
```
gcloud config set run/region REGION
```
將 REGION 替換為您選擇的支援 Cloud Run 區域。

Cloud Run 位置

Cloud Run 具有區域性，這表示執行 Cloud Run 服務的基礎架構位於特定區域，並由 Google 負責管理，實現該區域內所有可用區之間的備援可用性。

選擇執行 Cloud Run 服務的區域時，主要考量重點在於延遲時間、可用性或耐用性需求。原則上可以選擇距離使用者最近的區域，但也應考慮 Cloud Run 服務所用其他 Google Cloud產品的位置。如果跨多個位置使用 Google Cloud 產品，可能會影響服務的延遲時間和費用。

Cloud Run 可在下列地區使用：

採用級別 1 定價

asia-east1 (臺灣)
asia-northeast1 (東京)
asia-northeast2 (大阪)
asia-south1 (印度孟買)
asia-southeast3 (曼谷)
europe-north1 (芬蘭) 低二氧化碳排放
europe-north2 (斯德哥爾摩) 低二氧化碳排放
europe-southwest1 (馬德里) 低二氧化碳排放
europe-west1 (比利時) 低二氧化碳
europe-west4 (荷蘭) 低二氧化碳排放
europe-west8 (米蘭) 低二氧化碳排放
europe-west9 (巴黎) 低二氧化碳排放
me-west1 (特拉維夫)
northamerica-south1 (墨西哥)
us-central1 (愛荷華州) 低二氧化碳排放
us-east1 (南卡羅來納州)
us-east4 (北維吉尼亞州)
us-east5 (哥倫布)
us-south1 (達拉斯) 低二氧化碳排放
us-west1 (奧勒岡州) 低二氧化碳排放

採用級別 2 定價

africa-south1 (約翰尼斯堡)
asia-east2 (香港)
asia-northeast3 (韓國首爾)
asia-southeast1 (新加坡)
asia-southeast2 (雅加達)
asia-south2 (印度德里)
australia-southeast1 (雪梨)
australia-southeast2 (墨爾本)
europe-central2 (波蘭華沙) 低二氧化碳
europe-west10 (柏林)
europe-west12 (杜林) 低二氧化碳排放
europe-west2 (英國倫敦) 低二氧化碳排放
europe-west3 (德國法蘭克福)
europe-west6 (瑞士蘇黎世) 低二氧化碳
me-central1 (杜哈)
me-central2 (達曼)
northamerica-northeast1 (蒙特婁) 低二氧化碳排放
northamerica-northeast2 (多倫多) 低二氧化碳排放
southamerica-east1 (巴西聖保羅) 低二氧化碳排放
southamerica-west1 (智利聖地牙哥) 低二氧化碳排放
us-west2 (洛杉磯)
us-west3 (鹽湖城)
us-west4 (拉斯維加斯)

如果您已建立 Cloud Run 服務，可以在Google Cloud 控制台的 Cloud Run 資訊主頁中查看區域。

建立 Artifact Registry 標準存放區

建立 Artifact Registry 標準存放區，用於儲存容器映像檔：

gcloud artifacts repositories create REPOSITORY \
    --repository-format=docker \
    --location=REGION

更改項目：

REPOSITORY：存放區的專屬名稱。
REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。

建立 Pub/Sub 主題

範例服務是由發布至 Pub/Sub 主題的訊息觸發，因此您必須在 Pub/Sub 中建立主題。

gcloud

如要建立新的 Pub/Sub 主題，請使用下列指令：

gcloud pubsub topics create myRunTopic

您可以使用 myRunTopic，或替換成 Google Cloud 專案中不重複的主題名稱。

Terraform

如要瞭解如何套用或移除 Terraform 設定，請參閱「基本 Terraform 指令」。

如要建立 Pub/Sub 主題，請在現有的 main.tf 檔案中新增下列內容：

resource "google_pubsub_topic" "default" {
  name = "pubsub_topic"
}

您可以使用雲端專案中不重複的主題名稱。

擷取程式碼範例

如要擷取要使用的程式碼範例：

將應用程式存放區範例複製到本機電腦中：

Node.js

git clone https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git

您也可以下載範例 ZIP 檔案，然後解壓縮。

Python

git clone https://github.com/GoogleCloudPlatform/python-docs-samples.git

您也可以下載範例 ZIP 檔案，然後解壓縮。

Go

git clone https://github.com/GoogleCloudPlatform/golang-samples.git

您也可以下載範例 ZIP 檔案，然後解壓縮。

Java

git clone https://github.com/GoogleCloudPlatform/java-docs-samples.git

您也可以下載範例 ZIP 檔案，然後解壓縮。

C#

git clone https://github.com/GoogleCloudPlatform/dotnet-docs-samples.git

您也可以下載範例 ZIP 檔案，然後解壓縮。

變更為包含 Cloud Run 程式碼範例的目錄：

Node.js

cd nodejs-docs-samples/run/pubsub/

Python

cd python-docs-samples/run/pubsub/

Go

cd golang-samples/run/pubsub/

Java

cd java-docs-samples/run/pubsub/

C#

cd dotnet-docs-samples/run/Run.Samples.Pubsub.MinimalApi/

檢查程式碼

本教學課程的程式碼包含下列項目：

處理傳入要求的伺服器。

Node.js

為方便測試 Node.js 服務，伺服器設定與伺服器啟動作業會分開進行。

Node.js 網路伺服器是在 app.js 中設定。

const express = require('express');
const app = express();

// This middleware is available in Express v4.16.0 onwards
app.use(express.json());

網路伺服器會在 index.js 中啟動：

const app = require('./app.js');
const PORT = parseInt(parseInt(process.env.PORT)) || 8080;

app.listen(PORT, () =>
  console.log(`nodejs-pubsub-tutorial listening on port ${PORT}`)
);

Python

import base64

from flask import Flask, request


app = Flask(__name__)

Go


// Sample run-pubsub is a Cloud Run service which handles Pub/Sub messages.
package main

import (
	"encoding/json"
	"io"
	"log"
	"net/http"
	"os"
)

func main() {
	http.HandleFunc("/", HelloPubSub)
	// Determine port for HTTP service.
	port := os.Getenv("PORT")
	if port == "" {
		port = "8080"
		log.Printf("Defaulting to port %s", port)
	}
	// Start HTTP server.
	log.Printf("Listening on port %s", port)
	if err := http.ListenAndServe(":"+port, nil); err != nil {
		log.Fatal(err)
	}
}

Java

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class PubSubApplication {
  public static void main(String[] args) {
    SpringApplication.run(PubSubApplication.class, args);
  }
}

C#

var builder = WebApplication.CreateBuilder(args);
var app = builder.Build();

var port = Environment.GetEnvironmentVariable("PORT");
if (port != null)
{
    app.Urls.Add($"http://0.0.0.0:{port}");
}

處理 Pub/Sub 訊息並記錄問候語的處理常式。

Node.js

app.post('/', (req, res) => {
  if (!req.body) {
    const msg = 'no Pub/Sub message received';
    console.error(`error: ${msg}`);
    res.status(400).send(`Bad Request: ${msg}`);
    return;
  }
  if (!req.body.message) {
    const msg = 'invalid Pub/Sub message format';
    console.error(`error: ${msg}`);
    res.status(400).send(`Bad Request: ${msg}`);
    return;
  }

  const pubSubMessage = req.body.message;
  const name = pubSubMessage.data
    ? Buffer.from(pubSubMessage.data, 'base64').toString().trim()
    : 'World';

  console.log(`Hello ${name}!`);
  res.status(204).send();
});

Python

@app.route("/", methods=["POST"])
def index():
    """Receive and parse Pub/Sub messages."""
    envelope = request.get_json()
    if not envelope:
        msg = "no Pub/Sub message received"
        print(f"error: {msg}")
        return f"Bad Request: {msg}", 400

    if not isinstance(envelope, dict) or "message" not in envelope:
        msg = "invalid Pub/Sub message format"
        print(f"error: {msg}")
        return f"Bad Request: {msg}", 400

    pubsub_message = envelope["message"]

    name = "World"
    if isinstance(pubsub_message, dict) and "data" in pubsub_message:
        name = base64.b64decode(pubsub_message["data"]).decode("utf-8").strip()

    print(f"Hello {name}!")

    return ("", 204)

Go


// WrappedMessage is the payload of a Pub/Sub event.
//
// For more information about receiving messages from a Pub/Sub event
// see: https://cloud.google.com/pubsub/docs/push#receive_push
type WrappedMessage struct {
	Message struct {
		Data []byte `json:"data,omitempty"`
		ID   string `json:"id"`
	} `json:"message"`
	Subscription string `json:"subscription"`
}

// HelloPubSub receives and processes a Pub/Sub push message.
func HelloPubSub(w http.ResponseWriter, r *http.Request) {
	var m WrappedMessage
	body, err := io.ReadAll(r.Body)
	defer r.Body.Close()
	if err != nil {
		log.Printf("io.ReadAll: %v", err)
		http.Error(w, "Bad Request", http.StatusBadRequest)
		return
	}
	// byte slice unmarshalling handles base64 decoding.
	if err := json.Unmarshal(body, &m); err != nil {
		log.Printf("json.Unmarshal: %v", err)
		http.Error(w, "Bad Request", http.StatusBadRequest)
		return
	}

	name := string(m.Message.Data)
	if name == "" {
		name = "World"
	}
	log.Printf("Hello %s!", name)
}

Java

import com.example.cloudrun.Body;
import java.util.Base64;
import org.apache.commons.lang3.StringUtils;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

// PubsubController consumes a Pub/Sub message.
@RestController
public class PubSubController {
  @RequestMapping(value = "/", method = RequestMethod.POST)
  public ResponseEntity<String> receiveMessage(@RequestBody Body body) {
    // Get PubSub message from request body.
    Body.Message message = body.getMessage();
    if (message == null) {
      String msg = "Bad Request: invalid Pub/Sub message format";
      System.out.println(msg);
      return new ResponseEntity<>(msg, HttpStatus.BAD_REQUEST);
    }

    String data = message.getData();
    String target =
        !StringUtils.isEmpty(data) ? new String(Base64.getDecoder().decode(data)) : "World";
    String msg = "Hello " + target + "!";

    System.out.println(msg);
    return new ResponseEntity<>(msg, HttpStatus.OK);
  }
}

C#

app.MapPost("/", (Envelope envelope) =>
{
    if (envelope?.Message?.Data == null)
    {
        app.Logger.LogWarning("Bad Request: Invalid Pub/Sub message format.");
        return Results.BadRequest();
    }

    var data = Convert.FromBase64String(envelope.Message.Data);
    var target = System.Text.Encoding.UTF8.GetString(data);

    app.Logger.LogInformation($"Hello {target}!");

    return Results.NoContent();
});

您必須為服務設定代碼，以傳回準確的 HTTP 回應代碼。成功代碼 (例如 HTTP 200 或 204) 表示 Pub/Sub 訊息已處理完畢。HTTP 400 或 500 等錯誤代碼表示系統會重試訊息，詳情請參閱使用推送指南接收訊息。與使用 Cloud Functions v2 API 建立的函式不同，您無法停用使用 Cloud Run Admin API 建立的函式的重試功能。詳情請參閱「設定事件導向函式重試功能」。

Dockerfile：定義服務的運作環境。Dockerfile 的內容會因語言而異。

Node.js


# Use the official lightweight Node.js image.
# https://hub.docker.com/_/node
FROM node:20-slim
# Create and change to the app directory.
WORKDIR /usr/src/app

# Copy application dependency manifests to the container image.
# A wildcard is used to ensure both package.json AND package-lock.json are copied.
# Copying this separately prevents re-running npm install on every code change.
COPY package*.json ./

# Install dependencies.
# if you need a deterministic and repeatable build create a
# package-lock.json file and use npm ci:
# RUN npm ci --omit=dev
# if you need to include development dependencies during development
# of your application, use:
# RUN npm install --dev

RUN npm install --omit=dev

# Copy local code to the container image.
COPY . .

# Run the web service on container startup.
CMD [ "npm", "start" ]

Python


# Use the official Python image.
# https://hub.docker.com/_/python
FROM python:3.14

# Allow statements and log messages to immediately appear in the Cloud Run logs
ENV PYTHONUNBUFFERED True

# Copy application dependency manifests to the container image.
# Copying this separately prevents re-running pip install on every code change.
COPY requirements.txt ./

# Install production dependencies.
RUN pip install -r requirements.txt

# Copy local code to the container image.
ENV APP_HOME /app
WORKDIR $APP_HOME
COPY . ./

# Run the web service on container startup.
# Use gunicorn webserver with one worker process and 8 threads.
# For environments with multiple CPU cores, increase the number of workers
# to be equal to the cores available.
# Timeout is set to 0 to disable the timeouts of the workers to allow Cloud Run to handle instance scaling.
CMD exec gunicorn --bind :$PORT --workers 1 --threads 8 --timeout 0 main:app

Go


# Use the official Go image to create a binary.
# This is based on Debian and sets the GOPATH to /go.
# https://hub.docker.com/_/golang
FROM golang:1.25-bookworm as builder

# Create and change to the app directory.
WORKDIR /app

# Retrieve application dependencies.
# This allows the container build to reuse cached dependencies.
# Expecting to copy go.mod and if present go.sum.
COPY go.* ./
RUN go mod download

# Copy local code to the container image.
COPY . ./

# Build the binary.
RUN go build -v -o server

# Use the official Debian slim image for a lean production container.
# https://hub.docker.com/_/debian
# https://docs.docker.com/develop/develop-images/multistage-build/#use-multi-stage-builds
FROM debian:bookworm-slim
RUN set -x && apt-get update && DEBIAN_FRONTEND=noninteractive apt-get install -y \
    ca-certificates && \
    rm -rf /var/lib/apt/lists/*

# Copy the binary to the production image from the builder stage.
COPY --from=builder /app/server /server

# Run the web service on container startup.
CMD ["/server"]

Java

這個範例使用 Jib，透過常見的 Java 工具建構 Docker 映像檔。Jib 可最佳化容器建構作業，不需要 Dockerfile 或安裝 Docker。進一步瞭解如何使用 Jib 建構 Java 容器。

<plugin>
  <groupId>com.google.cloud.tools</groupId>
  <artifactId>jib-maven-plugin</artifactId>
  <version>3.4.0</version>
  <configuration>
    <to>
      <image>gcr.io/PROJECT_ID/pubsub</image>
    </to>
  </configuration>
</plugin>

C#

# Build in SDK base image
FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build-env
WORKDIR /app

COPY *.csproj ./
RUN dotnet restore

COPY . ./
RUN dotnet publish -r linux-x64 --no-self-contained -p:PublishReadyToRun=true -c Release -o out

# Copy to runtime image
FROM mcr.microsoft.com/dotnet/aspnet:6.0
WORKDIR /app
COPY --from=build-env /app/out .

# Port passed in by Cloud Run via environment variable PORT.  Default 8080.
ENV PORT=8080

ENTRYPOINT ["dotnet", "Run.Samples.Pubsub.MinimalApi.dll"]

如要進一步瞭解如何驗證 Pub/Sub 要求的來源，請參閱「與 Pub/Sub 整合」。

推送程式碼

推送程式碼包含三個步驟：使用 Cloud Build 建構容器映像檔、將容器映像檔上傳至 Artifact Registry，以及將容器映像檔部署至 Cloud Run。

如要推送程式碼：

建構容器並發布至 Artifact Registry：
Node.js
```
gcloud builds submit --tag REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub
```
替換：
- 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
- REPOSITORY：Artifact Registry 存放區名稱。
- REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。
pubsub 是映像檔名稱。

成功後，您應該會看到「SUCCESS」訊息，其中包含 ID、建立時間和映像檔名稱。映像檔會儲存在 Artifact Registry 中，日後如有需要，可以重複使用。
Python
```
gcloud builds submit --tag REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub
```
替換：
- 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
- REPOSITORY：Artifact Registry 存放區名稱。
- REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。
pubsub 是映像檔名稱。

成功後，您應該會看到「SUCCESS」訊息，其中包含 ID、建立時間和映像檔名稱。映像檔會儲存在 Artifact Registry 中，日後如有需要，可以重複使用。
Go
```
gcloud builds submit --tag REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub
```
替換：
- 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
- REPOSITORY：Artifact Registry 存放區名稱。
- REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。
pubsub 是映像檔名稱。

成功後，您應該會看到「SUCCESS」訊息，其中包含 ID、建立時間和映像檔名稱。映像檔會儲存在 Artifact Registry 中，日後如有需要，可以重複使用。
Java
- 使用 gcloud CLI 憑證輔助程式，授權 Docker 推送至 Artifact Registry。
  gcloud auth configure-docker
- 使用 Jib Maven 外掛程式建構容器，並推送至 Artifact Registry。
  mvn compile jib:build -D image=REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub
  更改項目：
  - 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
  - REPOSITORY：Artifact Registry 存放區名稱。
  - REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。
  pubsub 是映像檔名稱。
  
  成功後，您應該會看到「BUILD SUCCESS」訊息。映像檔會儲存在 Artifact Registry 中，日後如有需要，可以重複使用。
C#
```
gcloud builds submit --tag REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub
```
更改項目：
- 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
- REPOSITORY：Artifact Registry 存放區名稱。
- REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。
pubsub 是映像檔名稱。

成功後，您應該會看到「SUCCESS」訊息，其中包含 ID、建立時間和映像檔名稱。映像檔會儲存在 Artifact Registry 中，日後如有需要，可以重複使用。
部署應用程式：
指令列
1. 執行下列指令來部署您的應用程式：
  gcloud run deploy pubsub-tutorial --image REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub --no-allow-unauthenticated
  替換：
  - 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
  - REPOSITORY：Artifact Registry 存放區名稱。
  - REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。
  pubsub 是映像檔名稱，pubsub-tutorial 則是服務名稱。請注意，容器映像檔會部署到您先前在「設定 gcloud」下方設定的服務和區域
  
  --no-allow-unauthenticated 旗標會限制未經驗證的使用者存取服務。只要將服務設為私人，即可仰賴 Cloud Run 的自動 Pub/Sub 整合功能來驗證要求。如要進一步瞭解如何設定，請參閱「與 Pub/Sub 整合」。如要進一步瞭解以 Identity and Access Management (IAM) 為基礎的驗證，請參閱「使用 IAM 管理存取權」。
  
  等待部署作業完成，這項作業可能需要約半分鐘。部署成功後，指令列會顯示服務網址。這個網址用於設定 Pub/Sub 訂閱項目。
2. 如要將程式碼更新部署至服務，請重複上述步驟。每次部署服務都會建立新的修訂版本，並在準備就緒時自動開始提供流量。
Terraform

如要建立 Cloud Run 服務，請將下列內容新增至現有的 .tf 檔案。
```
resource "google_project_service" "cloudrun_api" {
   service            = "run.googleapis.com"
   disable_on_destroy = false
}

resource "google_cloud_run_v2_service" "default" {
   name     = "pubsub-tutorial"
   location = "REGION"

   template {
      containers {
         image = "IMAGE_URL"
     }
   }
   depends_on = [google_project_service.cloudrun_api]
}
         
```
替換：
- IMAGE_URL 替換成圖片網址：REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub
- REGION：Artifact Registry 存放區要使用的 Google Cloud 區域。

與 Pub/Sub 整合

如要將服務與 Pub/Sub 整合，請按照下列步驟操作：

gcloud

建立或選取服務帳戶，代表 Pub/Sub 訂閱項目身分。
```
gcloud iam service-accounts create cloud-run-pubsub-invoker \
    --display-name "Cloud Run Pub/Sub Invoker"
```
您可以使用 cloud-run-pubsub-invoker，或替換成 Google Cloud 專案中不重複的名稱。
使用服務帳戶建立 Pub/Sub 訂閱項目：
1. 授予叫用者服務帳戶叫用 pubsub-tutorial 服務的權限：
```
gcloud run services add-iam-policy-binding pubsub-tutorial \
--member=serviceAccount:cloud-run-pubsub-invoker@PROJECT_ID.iam.gserviceaccount.com \
--role=roles/run.invoker
```
  IAM 變更可能需要幾分鐘才會生效。在此期間，您可能會在服務記錄中看到 HTTP 403 錯誤。
2. 允許 Pub/Sub 在專案中建立驗證權杖：
```
gcloud projects add-iam-policy-binding PROJECT_ID \
   --member=serviceAccount:service-PROJECT_NUMBER@gcp-sa-pubsub.iam.gserviceaccount.com \
   --role=roles/iam.serviceAccountTokenCreator
```
  更改項目：
  - 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
  - PROJECT_NUMBER 替換為 Google Cloud 專案編號。
  專案 ID 和專案編號會列在Google Cloud 控制台的「Project info」(專案資訊) 面板中。
3. 使用服務帳戶建立 Pub/Sub 訂閱項目：
```
gcloud pubsub subscriptions create myRunSubscription --topic myRunTopic \
--ack-deadline=600 \
--push-endpoint=SERVICE-URL/ \
--push-auth-service-account=cloud-run-pubsub-invoker@PROJECT_ID.iam.gserviceaccount.com
```
  更改項目：
  - myRunTopic 替換為先前建立的主題。
  - SERVICE-URL 替換為部署服務時提供的 HTTPS 網址。即使您已新增網域對應，這個網址仍可正常運作。
  - 將 PROJECT_ID 替換為 Google Cloud 專案 ID。
  --push-auth-service-account 旗標會啟用 Pub/Sub 推送功能，用於驗證和授權。
  
  系統會自動註冊 Cloud Run 服務網域，以便與 Pub/Sub 訂閱項目搭配使用。
  
  僅限 Cloud Run：內建驗證檢查會確認權杖是否有效，授權檢查則會確認服務帳戶是否有權叫用 Cloud Run 服務。

服務現已與 Pub/Sub 完整整合。

Terraform

建立或選取服務帳戶，代表 Pub/Sub 訂閱項目身分。

resource "google_service_account" "sa" {
  account_id   = "cloud-run-pubsub-invoker"
  display_name = "Cloud Run Pub/Sub Invoker"
}

使用服務帳戶建立 Pub/Sub 訂閱項目：

授予叫用者服務帳戶叫用 pubsub-tutorial 服務的權限：

resource "google_cloud_run_service_iam_binding" "binding" {
  location = google_cloud_run_v2_service.default.location
  service  = google_cloud_run_v2_service.default.name
  role     = "roles/run.invoker"
  members  = ["serviceAccount:${google_service_account.sa.email}"]
}

允許 Pub/Sub 在專案中建立驗證權杖：

resource "google_project_service_identity" "pubsub_agent" {
  provider = google-beta
  project  = data.google_project.project.project_id
  service  = "pubsub.googleapis.com"
}

resource "google_project_iam_binding" "project_token_creator" {
  project = data.google_project.project.project_id
  role    = "roles/iam.serviceAccountTokenCreator"
  members = ["serviceAccount:${google_project_service_identity.pubsub_agent.email}"]
}

使用服務帳戶建立 Pub/Sub 訂閱項目：

resource "google_pubsub_subscription" "subscription" {
  name  = "pubsub_subscription"
  topic = google_pubsub_topic.default.name
  push_config {
    push_endpoint = google_cloud_run_v2_service.default.uri
    oidc_token {
      service_account_email = google_service_account.sa.email
    }
    attributes = {
      x-goog-version = "v1"
    }
  }
  depends_on = [google_cloud_run_v2_service.default]
}

服務現已與 Pub/Sub 完整整合。

立即體驗

測試端對端解決方案：

將 Pub/Sub 訊息傳送至主題：
```
gcloud pubsub topics publish myRunTopic --message "Runner"
```
您也可以使用程式發布訊息，而不使用本教學課程中使用的指令列。詳情請參閱發布訊息。
前往服務記錄：
1. 前往Google Cloud 控制台
2. 按一下「pubsub-tutorial」服務。
3. 選取 [Logs] (記錄) 分頁標籤。
  
  記錄需要一些時間才會出現。如果您沒有立即看到記錄，請稍候片刻再查看一次。
尋找「Hello Runner!」訊息。

清除所用資源

如要進一步瞭解如何搭配使用 Cloud Run 和 Pub/Sub，請先略過清理步驟，繼續進行使用 Cloud Run 處理圖片教學課程。

為避免系統向您的 Google Cloud 帳戶收取額外費用，請刪除您在本教學課程中部署的所有資源。

刪除專案

如果您是為了這個教學課程建立新專案，請刪除專案。如果您使用現有專案，並想保留專案，但不要本教學課程新增的變更，請刪除為本教學課程建立的資源。

如要避免付費，最簡單的方法就是刪除您為了本教學課程所建立的專案。

刪除專案的方法如下：

前往 Google Cloud 控制台的「Manage resources」(管理資源) 頁面。
前往「Manage resources」(管理資源)
在專案清單中選取要刪除的專案，然後點選「Delete」(刪除)。
在對話方塊中輸入專案 ID，然後按一下 [Shut down] (關閉) 以刪除專案。

刪除教學課程資源

刪除您在本教學課程中部署的 Cloud Run 服務。Cloud Run 服務在收到要求前不會產生費用。

如要刪除 Cloud Run 服務，請執行下列指令：
```
gcloud run services delete SERVICE-NAME
```
將 SERVICE-NAME 改為您的服務名稱。

您也可以從Google Cloud 控制台刪除 Cloud Run 服務。
移除您在教學課程設定期間新增的 gcloud 預設區域設定：
```
 gcloud config unset run/region
```
移除專案設定：
```
 gcloud config unset project
```
刪除在本教學課程中建立的其他 Google Cloud 資源：
- 刪除 Pub/Sub 主題 myRunTopic
- 刪除 Pub/Sub 訂閱項目 myRunSubscription
- 從 Artifact Registry 刪除容器映像檔 REGION-docker.pkg.dev/PROJECT_ID/REPOSITORY/pubsub。
- 刪除叫用者服務帳戶 cloud-run-pubsub-invoker@PROJECT_ID.iam.gserviceaccount.com

後續步驟

瞭解如何設定重試。
如要瞭解如何使用內部輸入控管機制限制輸入，進而提高正式環境安全性，請參閱「限制輸入」。
擴充本教學課程中部署的範例服務，新增圖片處理功能，修改上傳至 Cloud Storage 的圖片。
進一步瞭解主題在 Pub/Sub 架構中的角色，以及如何管理主題
如要進一步瞭解 Pub/Sub 訂閱項目，請參閱「管理訂閱項目」。
查看 Google Cloud 的參考架構、圖表和最佳做法。歡迎瀏覽 Cloud Architecture Center。

搭配 Cloud Run 使用 Pub/Sub 教學課程 透過集合功能整理內容 你可以依據偏好儲存及分類內容。

目標

費用

事前準備

必要的角色

設定 gcloud 預設值

Cloud Run 位置

採用級別 1 定價

採用級別 2 定價

建立 Artifact Registry 標準存放區

建立 Pub/Sub 主題

gcloud

Terraform

擷取程式碼範例

Node.js

Python

Go

Java

C#

Node.js

Python

Go

Java

C#

檢查程式碼

Node.js

Python

Go

Java

C#

Node.js

Python

Go

Java

C#

Node.js

Python

Go

Java

C#

推送程式碼

Node.js

Python

Go

Java

C#

指令列

Terraform

與 Pub/Sub 整合

gcloud

Terraform

立即體驗

清除所用資源

刪除專案

刪除教學課程資源

後續步驟

搭配 Cloud Run 使用 Pub/Sub 教學課程