Thema mit SMTs erstellen

Console

1. Rufen Sie in der Google Cloud Console die Pub/Sub-Seite Themen auf.

   Themen aufrufen

2. Klicken Sie auf Thema erstellen.

   Die Seite Thema erstellen wird geöffnet.

3. Geben Sie im Feld Themen-ID eine ID für das Thema ein. Weitere Informationen zur Benennung von Themen finden Sie in den Benennungsrichtlinien.

4. Klicken Sie unter Transformationen auf Transformation hinzufügen.

5. Geben Sie einen Funktionsnamen ein. Beispiel: redactSSN.

6. Wenn Sie die SMT nicht sofort auf Ihr Thema anwenden möchten, klicken Sie auf die Option Transformation deaktivieren. Die SMT wird weiterhin gespeichert, aber nicht ausgeführt, wenn Nachrichten über Ihr Thema gesendet werden.

7. Geben Sie eine neue Transformation ein. Beispiel:

   function redactSSN(message, metadata) {
     const data = JSON.parse(message.data);
     delete data['ssn'];
     message.data = JSON.stringify(data);
     return message;
   }

8. Pub/Sub bietet eine Validierungsfunktion, mit der Sie eine SMT validieren können. Klicken Sie auf Validieren, um die Transformation zu validieren.

9. Wenn Sie eine weitere Transformation hinzufügen möchten, klicken Sie auf Transformation hinzufügen.

10. Mit den Auf- und Abwärtspfeilen können Sie alle SMTs in einer bestimmten Reihenfolge anordnen. Wenn Sie ein SMT entfernen möchten, klicken Sie auf die Schaltfläche „Löschen“.

11. Pub/Sub bietet eine Testfunktion, mit der Sie das Ergebnis der Ausführung des SMT für eine Beispielnachricht prüfen können. Wenn Sie die SMTs testen möchten, klicken Sie auf Transformation testen.

12. Wählen Sie im Fenster Testtransformierung die Funktion aus, die Sie testen möchten.

13. Geben Sie im Fenster Eingabenachricht eine Beispielnachricht ein.

14. Wenn Sie Nachrichtenattribute hinzufügen möchten, klicken Sie auf Attribut hinzufügen und geben Sie ein oder mehrere Schlüssel/Wert-Paare ein.

15. Klicken Sie auf Testen. Das Ergebnis der Anwendung der SMTs auf die Nachricht wird angezeigt.

16. Schließen Sie das Fenster, um das Testen von SMTs für Beispielnachrichten zu beenden.

17. Klicken Sie auf Erstellen, um das Thema zu erstellen.

gcloud

1. In the Google Cloud console, activate Cloud Shell.

   Activate Cloud Shell

   At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

2. Pub/Sub bietet eine Validierungsfunktion, mit der Sie ein SMT validieren können. Führen Sie den Befehl gcloud pubsub message-transforms validate aus:

   gcloud pubsub message-transforms validate --message-transform-file=TRANSFORM_FILE

   Ersetzen Sie Folgendes:

   • TRANSFORM_FILE: Der Pfad zur YAML- oder JSON-Datei, die ein einzelnes SMT enthält.

     Hier ist ein Beispiel für eine YAML-Transformationsdatei:

     - javascriptUdf:
         code: >
             function redactSSN(message, metadata) {
               const data = JSON.parse(message.data);
               delete data['ssn'];
               message.data = JSON.stringify(data);
               return message;
             }
         functionName: redactSSN

3. Pub/Sub bietet eine Testfunktion, mit der Sie das Ergebnis der Ausführung von einem oder mehreren SMTs für eine Beispielnachricht prüfen können. Führen Sie den Befehl gcloud pubsub message-transforms test aus:

   gcloud pubsub message-transforms test --message-transforms-file=TRANSFORMS_FILE --message=MESSAGE --attributes=ATTRIBUTES

   Ersetzen Sie Folgendes:

   • TRANSFORMS_FILE: Der Pfad zur YAML- oder JSON-Datei, die ein oder mehrere SMTs enthält.

     Hier ist ein Beispiel für eine YAML-Datei mit Transformationen:

     - javascriptUdf:
         code: >
             function redactSSN(message, metadata) {
               const data = JSON.parse(message.data);
               delete data['ssn'];
               message.data = JSON.stringify(data);
               return message;
             }
         functionName: redactSSN

   • MESSAGE: Nachrichtentext, mit dem die SMTs getestet werden sollen.

   • ATTRIBUTES: Nachrichtenattribute, mit denen die SMTs getestet werden sollen.

4. Führen Sie den Befehl gcloud pubsub topics create aus, um das Thema zu erstellen:

   gcloud pubsub topics create TOPIC_ID \
    --message-transforms-file=TRANSFORMS_FILE

   Ersetzen Sie Folgendes:

   • TOPIC_ID: Die ID oder der Name des Themas, das Sie erstellen möchten. Richtlinien zum Benennen eines Themas finden Sie unter Ressourcennamen. Der Name eines Themas kann nicht geändert werden.

   • TRANSFORMS_FILE: Der Pfad zur YAML- oder JSON-Datei, die ein oder mehrere SMTs enthält.

     Hier ist ein Beispiel für eine YAML-Datei mit Transformationen:

     - javascriptUdf:
         code: >
             function redactSSN(message, metadata) {
               const data = JSON.parse(message.data);
               delete data['ssn'];
               message.data = JSON.stringify(data);
               return message;
             }
         functionName: redactSSN

Java

Folgen Sie der Einrichtungsanleitung für Java in der Pub/Sub-Kurzanleitung: Clientbibliotheken verwenden, bevor Sie dieses Beispiel anwenden. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Java API.

Richten Sie zur Authentifizierung bei Pub/Sub Standardanmeldedaten für Anwendungen ein. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.

import com.google.api.gax.rpc.AlreadyExistsException;
import com.google.cloud.pubsub.v1.TopicAdminClient;
import com.google.pubsub.v1.JavaScriptUDF;
import com.google.pubsub.v1.MessageTransform;
import com.google.pubsub.v1.Topic;
import com.google.pubsub.v1.TopicName;
import java.io.IOException;

public class CreateTopicWithSmtExample {

  public static void main(String... args) throws Exception {
    // TODO(developer): Replace these variables before running the sample.
    String projectId = "your-project-id";
    String topicId = "your-topic-id";

    createTopicWithSmtExample(projectId, topicId);
  }

  public static void createTopicWithSmtExample(String projectId, String topicId)
      throws IOException {
    TopicName topicName = TopicName.of(projectId, topicId);

    // UDF that removes the 'ssn' field, if present
    String code =
        "function redactSSN(message, metadata) {"
            + "  const data = JSON.parse(message.data);"
            + "  delete data['ssn'];"
            + "  message.data = JSON.stringify(data);"
            + "  return message;"
            + "}";
    String functionName = "redactSSN";

    JavaScriptUDF udf =
        JavaScriptUDF.newBuilder().setCode(code).setFunctionName(functionName).build();
    MessageTransform transform = MessageTransform.newBuilder().setJavascriptUdf(udf).build();
    try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {

      Topic topic =
          topicAdminClient.createTopic(
              Topic.newBuilder()
                  .setName(topicName.toString())
                  // Add the UDF message transform
                  .addMessageTransforms(transform)
                  .build());

      System.out.println("Created topic with SMT: " + topic.getName());
    } catch (AlreadyExistsException e) {
      System.out.println(topicName + "already exists.");
    }
  }
}

Python

Folgen Sie der Einrichtungsanleitung für Python in der Pub/Sub-Kurzanleitung: Clientbibliotheken verwenden, bevor Sie dieses Beispiel anwenden. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Python API.

Richten Sie zur Authentifizierung bei Pub/Sub Standardanmeldedaten für Anwendungen ein. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.

from google.cloud import pubsub_v1
from google.pubsub_v1.types import JavaScriptUDF, MessageTransform, Topic

# TODO(developer)
# project_id = "your-project-id"
# topic_id = "your-topic-id"

code = """function redactSSN(message, metadata) {
            const data = JSON.parse(message.data);
            delete data['ssn'];
            message.data = JSON.stringify(data);
            return message;
            }"""
udf = JavaScriptUDF(code=code, function_name="redactSSN")
transforms = [MessageTransform(javascript_udf=udf)]

publisher = pubsub_v1.PublisherClient()
topic_path = publisher.topic_path(project_id, topic_id)

request = Topic(name=topic_path, message_transforms=transforms)

topic = publisher.create_topic(request=request)

print(f"Created topic: {topic.name} with SMT")

Go

Folgen Sie der Einrichtungsanleitung für Go in der Pub/Sub-Kurzanleitung: Clientbibliotheken verwenden, bevor Sie dieses Beispiel anwenden. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Go API.

Richten Sie zur Authentifizierung bei Pub/Sub Standardanmeldedaten für Anwendungen ein. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.

// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package topics

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/pubsub"
)

// createTopicWithSMT creates a topic with a single message transform function applied.
func createTopicWithSMT(w io.Writer, projectID, topicID string) error {
	// projectID := "my-project-id"
	// topicID := "my-topic"
	ctx := context.Background()
	client, err := pubsub.NewClient(ctx, projectID)
	if err != nil {
		return fmt.Errorf("pubsub.NewClient: %w", err)
	}
	defer client.Close()

	code := `function redactSSN(message, metadata) {
			const data = JSON.parse(message.data);
			delete data['ssn'];
			message.data = JSON.stringify(data);
			return message;
		}`
	transform := pubsub.MessageTransform{
		Transform: pubsub.JavaScriptUDF{
			FunctionName: "redactSSN",
			Code:         code,
		},
	}
	cfg := &pubsub.TopicConfig{
		MessageTransforms: []pubsub.MessageTransform{transform},
	}
	t, err := client.CreateTopicWithConfig(ctx, topicID, cfg)
	if err != nil {
		return fmt.Errorf("CreateTopic: %w", err)
	}

	fmt.Fprintf(w, "Created topic with message transform: %v\n", t)
	return nil
}