Thema erstellen

In Pub/Sub ist ein Thema eine benannte Ressource, die einen Nachrichtenfeed darstellt. Bevor Sie ein Thema veröffentlichen oder abonnieren können, müssen Sie es zuerst erstellen. Pub/Sub unterstützt zwei Arten von Themen: ein Standardthema und ein Importthema.

In diesem Dokument wird beschrieben, wie Sie ein Pub/Sub-Standardthema erstellen. Weitere Informationen zu Importthemen und zum Erstellen von Importthemen finden Sie unter Importthemen.

Sie können ein Thema mit der Google Cloud Console, der Google Cloud CLI, der Clientbibliothek oder der Pub/Sub API erstellen.

Hinweise

• Weitere Informationen zum Pub/Sub-Dienst und zur zugehörigen Terminologie

• Weitere Informationen zum Veröffentlichungsprozess

Erforderliche Rollen und Berechtigungen zum Verwalten von Themen

Bitten Sie Ihren Administrator, Ihnen die IAM-Rolle „Pub/Sub Editor“ (roles/pubsub.editor) für Ihr Thema oder Projekt zuzuweisen, um die Berechtigungen zu erhalten, die Sie zum Erstellen und Verwalten von Themen benötigen. Weitere Informationen zum Zuweisen von Rollen finden Sie unter Zugriff auf Projekte, Ordner und Organisationen verwalten.

Diese vordefinierte Rolle enthält die Berechtigungen, die zum Erstellen und Verwalten von Themen erforderlich sind. Erweitern Sie den Abschnitt Erforderliche Berechtigungen, um die erforderlichen Berechtigungen anzuzeigen:

Sie können diese Berechtigungen auch mit benutzerdefinierten Rollen oder anderen vordefinierten Rollen erhalten.

Sie können die Zugriffssteuerung auf Projektebene und auf der Ebene einzelner Ressourcen konfigurieren. Sie können ein Abo in einem Projekt erstellen und es einem Thema in einem anderen Projekt zuordnen. Sie müssen die erforderlichen Berechtigungen für jedes Projekt haben.

Eigenschaften eines Themas

Wenn Sie ein Thema erstellen oder aktualisieren, müssen Sie die zugehörigen Eigenschaften angeben.

Standardabo hinzufügen

Dem Pub/Sub-Thema wird ein Standardabo hinzugefügt. Sie können ein weiteres Abo für das Thema erstellen, nachdem es erstellt wurde. Das Standardabo hat folgende Eigenschaften:

• Abo-ID von -sub
• Pull-Zustellungstyp
• Nachrichtenaufbewahrung für sieben Tage
• Ablauf nach 31 Tagen Inaktivität
• Bestätigungsfrist von 10 Sekunden
• Richtlinie für sofortige Wiederholung

Schema verwenden

Ein Schema ist ein Format, dem das Nachrichtendatenfeld entsprechen muss. Ein Schema ist ein Vertrag zwischen Publisher und Abonnent, der von Pub/Sub erzwungen wird. Mithilfe von Themenschemata können Nachrichtentypen und Berechtigungen standardisiert werden, damit sie von verschiedenen Teams in Ihrer Organisation verwendet werden können. Pub/Sub erstellt eine zentrale Stelle für Nachrichtentypen und -berechtigungen. Informationen zum Erstellen eines Themas mit Schema finden Sie unter Schemaübersicht.

Aufnahme aktivieren

Wenn Sie diese Property aktivieren, können Sie Streamingdaten aus externen Quellen in ein Thema aufnehmen und die Funktionen von Google Cloud nutzen. Informationen zum Erstellen eines Importthemas für die Datenaufnahme:

• Amazon Kinesis Data Streams-Importthema erstellen

• Cloud Storage-Importthema erstellen

Nachrichtenaufbewahrung aktivieren

Gibt an, wie lange das Pub/Sub-Thema Nachrichten nach der Veröffentlichung aufbewahrt. Nach Ablauf der Nachrichtenaufbewahrungsdauer kann Pub/Sub die Nachricht unabhängig vom Bestätigungsstatus verwerfen. Für die Speicherung aller zu diesem Thema veröffentlichten Nachrichten werden Speichergebühren für Nachrichten berechnet.

• Standardeinstellung: Deaktiviert
• Mindestwert: 10 Minuten
• Maximalwert: 31 Tage

Daten der Exportnachricht an BigQuery

Wenn Sie diese Eigenschaft aktivieren, können Sie ein BigQuery-Abo erstellen, das Nachrichten beim Empfang in eine vorhandene BigQuery-Tabelle schreibt. Du musst keinen separaten Abonnentenclient konfigurieren. Weitere Informationen zu BigQuery-Abos finden Sie unter BigQuery-Abos.

Nachrichtendaten in Cloud Storage exportieren

Wenn Sie diese Property aktivieren, können Sie ein Cloud Storage-Abo erstellen, das empfangene Nachrichten in eine vorhandene Cloud Storage-Tabelle schreibt. Du musst keinen separaten Abonnentenclient konfigurieren. Weitere Informationen zu Cloud Storage-Abos finden Sie unter Cloud Storage-Abos.

Von Google verwalteter Verschlüsselungsschlüssel

Gibt an, dass das Thema mit von Google verwalteten Verschlüsselungsschlüsseln verschlüsselt wird. Pub/Sub verschlüsselt Nachrichten standardmäßig mit von Google verwalteten Schlüsseln. Wenn Sie diese Option auswählen, bleibt das Standardverhalten erhalten. Google übernimmt die Schlüsselverwaltung und ‑rotation automatisch, damit Ihre Nachrichten immer mit der stärksten verfügbaren Verschlüsselung geschützt sind. Für diese Option ist keine weitere Konfiguration erforderlich. Weitere Informationen zu von Google verwalteten Verschlüsselungsschlüsseln finden Sie unter Standardverschlüsselung mit Google-eigenen und von Google verwalteten Schlüsseln.

Cloud KMS-Schlüssel

Gibt an, ob das Thema mit einem vom Kunden verwalteten Verschlüsselungsschlüssel (CMEK) verschlüsselt ist. Pub/Sub verschlüsselt Nachrichten standardmäßig mit von Google verwalteten Schlüsseln. Wenn Sie diese Option angeben, verwendet Pub/Sub das Envelope-Verschlüsselungsmuster mit CMEK. Bei diesem Ansatz werden die Nachrichten nicht von Cloud KMS verschlüsselt. Stattdessen werden die Data Encryption Keys (DEKs), die von Pub/Sub für jedes Thema erstellt werden, mit Cloud KMS verschlüsselt. Pub/Sub verschlüsselt die Nachrichten mit dem neuesten DEK, das für das Thema generiert wurde. Pub/Sub entschlüsselt die Nachrichten kurz vor der Zustellung an Abonnenten. Weitere Informationen zum Erstellen eines Schlüssels finden Sie unter Nachrichtenverschlüsselung konfigurieren.

Thema erstellen

Bevor Sie ein Thema veröffentlichen oder abonnieren können, müssen Sie es zuerst erstellen.

PUT https://pubsub.googleapis.com/v1/projects/PROJECT_ID/topics/TOPIC_ID
Authorization: Bearer ACCESS_TOKEN
    

{
 "name": "projects/PROJECT_ID/topics/TOPIC_ID"
}

namespace pubsub = ::google::cloud::pubsub;
namespace pubsub_admin = ::google::cloud::pubsub_admin;
[](pubsub_admin::TopicAdminClient client, std::string project_id,
   std::string topic_id) {
  auto topic = client.CreateTopic(
      pubsub::Topic(std::move(project_id), std::move(topic_id)).FullName());
  // Note that kAlreadyExists is a possible error when the library retries.
  if (topic.status().code() == google::cloud::StatusCode::kAlreadyExists) {
    std::cout << "The topic already exists\n";
    return;
  }
  if (!topic) throw std::move(topic).status();

  std::cout << "The topic was successfully created: " << topic->DebugString()
            << "\n";
}

using Google.Cloud.PubSub.V1;
using Grpc.Core;
using System;

public class CreateTopicSample
{
    public Topic CreateTopic(string projectId, string topicId)
    {
        PublisherServiceApiClient publisher = PublisherServiceApiClient.Create();
        var topicName = TopicName.FromProjectTopic(projectId, topicId);
        Topic topic = null;

        try
        {
            topic = publisher.CreateTopic(topicName);
            Console.WriteLine($"Topic {topic.Name} created.");
        }
        catch (RpcException e) when (e.Status.StatusCode == StatusCode.AlreadyExists)
        {
            Console.WriteLine($"Topic {topicName} already exists.");
        }
        return topic;
    }
}

import (
	"context"
	"fmt"
	"io"

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

func create(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()

	t, err := client.CreateTopic(ctx, topicID)
	if err != nil {
		return fmt.Errorf("CreateTopic: %w", err)
	}
	fmt.Fprintf(w, "Topic created: %v\n", t)
	return nil
}

import com.google.cloud.pubsub.v1.TopicAdminClient;
import com.google.pubsub.v1.Topic;
import com.google.pubsub.v1.TopicName;
import java.io.IOException;

public class CreateTopicExample {
  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";

    createTopicExample(projectId, topicId);
  }

  public static void createTopicExample(String projectId, String topicId) throws IOException {
    try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
      TopicName topicName = TopicName.of(projectId, topicId);
      Topic topic = topicAdminClient.createTopic(topicName);
      System.out.println("Created topic: " + topic.getName());
    }
  }
}

/**
 * TODO(developer): Uncomment this variable before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';

// Imports the Google Cloud client library
const {PubSub} = require('@google-cloud/pubsub');

// Creates a client; cache this for further use
const pubSubClient = new PubSub();

async function createTopic(topicNameOrId) {
  // Creates a new topic
  await pubSubClient.createTopic(topicNameOrId);
  console.log(`Topic ${topicNameOrId} created.`);
}

/**
 * TODO(developer): Uncomment this variable before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';

// Imports the Google Cloud client library
import {PubSub} from '@google-cloud/pubsub';

// Creates a client; cache this for further use
const pubSubClient = new PubSub();

async function createTopic(topicNameOrId: string) {
  // Creates a new topic
  await pubSubClient.createTopic(topicNameOrId);
  console.log(`Topic ${topicNameOrId} created.`);
}

use Google\Cloud\PubSub\PubSubClient;

/**
 * Creates a Pub/Sub topic.
 *
 * @param string $projectId  The Google project ID.
 * @param string $topicName  The Pub/Sub topic name.
 */
function create_topic($projectId, $topicName)
{
    $pubsub = new PubSubClient([
        'projectId' => $projectId,
    ]);
    $topic = $pubsub->createTopic($topicName);

    printf('Topic created: %s' . PHP_EOL, $topic->name());
}

from google.cloud import pubsub_v1

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

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

topic = publisher.create_topic(request={"name": topic_path})

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

# topic_id = "your-topic-id"

pubsub = Google::Cloud::Pubsub.new

topic = pubsub.create_topic topic_id

puts "Topic #{topic.name} created."

Einschränkungen für Organisationsrichtlinien

Organisationsrichtlinien können die Themenerstellung einschränken. So kann beispielsweise die Nachrichtenspeicherung in einer Compute Engine-Region eingeschränkt werden. Prüfen und aktualisieren Sie die Organisationsrichtlinien vor dem Erstellen eines Themas, um Fehler beim Erstellen zu vermeiden.

Wenn Ihr Projekt neu erstellt wurde, warten Sie einige Minuten, bis die Organisationsrichtlinie initialisiert wurde, bevor Sie ein Thema erstellen.

Zu den Organisationsrichtlinien

Weitere Informationen finden Sie unter Richtlinien für den Nachrichtenspeicher konfigurieren.

Nächste Schritte

• Wählen Sie den Abotyp für Ihr Thema aus.

• Weitere Informationen zum Veröffentlichen von Nachrichten in einem Thema

• Themen mit der gcloud CLI, REST APIs oder Clientbibliotheken erstellen oder ändern