使用 Pub/Sub 訂閱主題

示範如何從 Cloud Functions，使用 Pub/Sub 訂閱主題及剖析收到的事件。

程式碼範例

Java

如要進行驗證以使用 Cloud Run functions，請設定應用程式預設憑證。 詳情請參閱這篇文章，瞭解如何設定本機開發環境的驗證機制。

import com.google.cloud.functions.BackgroundFunction;
import com.google.cloud.functions.Context;
import functions.eventpojos.PubsubMessage;
import java.nio.charset.StandardCharsets;
import java.util.Base64;
import java.util.logging.Logger;

public class SubscribeToTopic implements BackgroundFunction<PubsubMessage> {
  private static final Logger logger = Logger.getLogger(SubscribeToTopic.class.getName());

  @Override
  public void accept(PubsubMessage message, Context context) {
    if (message.getData() == null) {
      logger.info("No message provided");
      return;
    }

    String messageString = new String(
        Base64.getDecoder().decode(message.getData().getBytes(StandardCharsets.UTF_8)),
        StandardCharsets.UTF_8);
    logger.info(messageString);
  }
}

Node.js

如要進行驗證以使用 Cloud Run functions，請設定應用程式預設憑證。 詳情請參閱這篇文章，瞭解如何設定本機開發環境的驗證機制。

/**
 * Triggered from a message on a Cloud Pub/Sub topic.
 *
 * @param {object} pubsubMessage The Cloud Pub/Sub Message object.
 * @param {string} pubsubMessage.data The "data" property of the Cloud Pub/Sub Message.
 */
exports.subscribe = pubsubMessage => {
  // Print out the data from Pub/Sub, to prove that it worked
  console.log(Buffer.from(pubsubMessage.data, 'base64').toString());
};

Python

如要進行驗證以使用 Cloud Run functions，請設定應用程式預設憑證。 詳情請參閱這篇文章，瞭解如何設定本機開發環境的驗證機制。

# Triggered from a message on a Cloud Pub/Sub topic.
def subscribe(event, context):
    # Print out the data from Pub/Sub, to prove that it worked
    print(base64.b64decode(event["data"]))

後續步驟

如要搜尋及篩選其他 Google Cloud 產品的程式碼範例，請參閱Google Cloud 範例瀏覽工具。