會使用 Cloud Logging 的第二方觸發條件

許多 Google Cloud 事件都會記錄在 Cloud 稽核記錄中。您可以篩選這些記錄，並使用接收器將其轉送至 Pub/Sub 主題。之後 Pub/Sub 主題可傳送通知，以觸發 Cloud Run 函式。這樣您就可以透過產生稽核記錄的任何 Google Cloud 服務建立自訂事件。

設定

如要執行本文中的範例，您需要 Pub/Sub 主題和 Cloud Logging 接收器。以便讓範例將 Cloud 稽核記錄轉送至 Cloud Run 函式。

事件結構

和所有 Pub/Sub 觸發函式一樣，由 Cloud 記錄項目觸發的函式會收到 PubsubMessage 物件，這個物件的 data 參數是採 base64 編碼的字串。對 Cloud 記錄事件而言，解碼此值會以 JSON 字串傳回相關記錄項目。

程式碼範例

您可利用 Pub/Sub 觸發函式，偵測及回應匯出的 Cloud 記錄：

Node.js

exports.processLogEntry = data => {
  const dataBuffer = Buffer.from(data.data, 'base64');

  const logEntry = JSON.parse(dataBuffer.toString('ascii')).protoPayload;
  console.log(`Method: ${logEntry.methodName}`);
  console.log(`Resource: ${logEntry.resourceName}`);
  console.log(`Initiator: ${logEntry.authenticationInfo.principalEmail}`);
};

Python

import base64
import json

def process_log_entry(data, context):
    data_buffer = base64.b64decode(data["data"])
    log_entry = json.loads(data_buffer)["protoPayload"]

    print(f"Method: {log_entry['methodName']}")
    print(f"Resource: {log_entry['resourceName']}")
    print(f"Initiator: {log_entry['authenticationInfo']['principalEmail']}")

Go

// Package log contains examples for handling Cloud Functions logs.
package log

import (
	"context"
	"log"
)

// PubSubMessage is the payload of a Pub/Sub event.
// See the documentation for more details:
// https://cloud.google.com/pubsub/docs/reference/rest/v1/PubsubMessage
type PubSubMessage struct {
	Data []byte `json:"data"`
}

// ProcessLogEntry processes a Pub/Sub message from Cloud Logging.
func ProcessLogEntry(ctx context.Context, m PubSubMessage) error {
	log.Printf("Log entry data: %s", string(m.Data))
	return nil
}

Java

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 StackdriverLogging implements BackgroundFunction<PubsubMessage> {
  private static final Logger logger = Logger.getLogger(StackdriverLogging.class.getName());

  @Override
  public void accept(PubsubMessage message, Context context) {
    String name = "World";

    if (!message.getData().isEmpty()) {
      name = new String(Base64.getDecoder().decode(
          message.getData().getBytes(StandardCharsets.UTF_8)), StandardCharsets.UTF_8);
    }
    String res = String.format("Hello, %s", name);
    logger.info(res);
  }
}

部署函式

使用下列指令部署函式：

Node.js

gcloud functions deploy processLogEntry \
--runtime nodejs20 \
--trigger-topic YOUR_PUBSUB_TOPIC/
FLAGS...

使用 --runtime 標記指定支援的 Node.js 版本執行階段 ID，以執行函式。

Python

gcloud functions deploy process_log_entry \
--runtime python312 \
--trigger-topic YOUR_PUBSUB_TOPIC/
FLAGS...

使用 --runtime 標記指定支援的 Python 版本執行階段 ID，以執行函式。

Go

gcloud functions deploy ProcessLogEntry \
--runtime go121 \
--trigger-topic YOUR_PUBSUB_TOPIC/
FLAGS...

使用 --runtime 標記指定支援的 Go 版本執行階段 ID，以執行函式。

Java

gcloud functions deploy java-log-function \
--entry-point StackdriverLogging \
--runtime java17 \
--memory 512MB \
--trigger-topic YOUR_PUBSUB_TOPIC/
FLAGS...

使用 --runtime 標記指定支援的 Java 版本執行函式的執行階段 ID。

觸發函式

如果系統建立了符合其中一個篩選條件的 Cloud 記錄項目，您應會看見函式的對應記錄項目：

Method: METHOD
Resource: projects/YOUR_GCLOUD_PROJECT/...
Initiator: YOUR_EMAIL_ADDRESS