Cómo crear un tema

En Pub/Sub, un tema es un recurso con nombre que representa un feed de mensajes. Debes crear un tema para poder publicarlo o suscribirte que se les asigna. Pub/Sub admite dos tipos de temas: uno estándar y un tema de importación.

En este documento, se describe cómo crear un tema estándar de Pub/Sub. Si Si quieres saber más sobre un tema de importación y cómo crear uno, consulta Crea un tema de importación.

Para crear un tema, puedes usar la consola de Google Cloud, Google Cloud CLI, la biblioteca cliente o la API de Pub/Sub.

Antes de comenzar

• Obtén más información sobre el servicio de Pub/Sub y su terminología.

• Obtén más información sobre el proceso de publicación.

Roles y permisos obligatorios para administrar temas

Para obtener los permisos que necesitas para crear y administrar temas, solicita a tu administrador que te otorgue el Editor de Pub/Sub(roles/pubsub.editor) IAM en tu tema o proyecto. Para obtener más información sobre cómo otorgar roles, consulta Cómo administrar el acceso.

Este rol predefinido contiene los permisos necesarios para crear y administrar temas. Para ver los permisos exactos que son necesarios, expande la sección Permisos requeridos:

También puedes obtener estos permisos con roles personalizados o con otros roles predefinidos

Puedes configurar el control de acceso a nivel de proyecto y a nivel individual a nivel de los recursos. Puedes crear una suscripción en un proyecto adjuntarlo a un tema ubicado en un proyecto diferente. Asegúrate de tener los permisos necesarios para cada proyecto.

Propiedades de un tema

Cuando creas o actualizas un tema, debes especificar sus propiedades.

• Agrega una suscripción predeterminada. Agrega una suscripción predeterminada al tema de Pub/Sub. Puedes crear otra suscripción para el tema una vez creado el tema. La suscripción predeterminada tiene la siguientes propiedades:

  • ID de suscripción de -sub
  • Tipo de entrega de extracción
  • Período de retención de mensajes de siete días
  • Vencimiento después de 31 días de inactividad
  • El plazo límite de confirmación de recepción es de 10 segundos
  • Política de reintento inmediato
• Esquema. Un esquema es un formato en el que el campo de datos del mensaje debe seguir. Un esquema es un contrato entre el publicador y el suscriptor que Pub/Sub aplica. Los esquemas de temas ayudan a estandarizar tipos de mensajes y permisos para permitirles que los usen diferentes equipos de tu organización. Pub/Sub crea un autoridad para los tipos de mensajes y permisos. Para crear un tema con , consulta Descripción general del esquema.

• Habilita la transferencia. Habilitar esta propiedad te permite transferir datos de transmisión de fuentes externas a un tema para que puedan aprovechar las funciones de Google Cloud. Para crear un tema de importación Para la transferencia, consulta Crea un tema de importación.

• Duración de la retención de mensajes. Especifica la duración El tema de Pub/Sub conserva los mensajes después de la publicación. Después del cuando finalice la retención de mensajes, es posible que Pub/Sub descarte el mensaje independientemente de su estado de confirmación. Tarifas de almacenamiento de mensajes se cobran por almacenar todos los mensajes publicados en el tema.

  • Configuración predeterminada = No habilitada
  • Valor mínimo = 10 minutos
  • Valor máximo = 31 días
• Usa una clave de encriptación administrada por el cliente (CMEK). Especifica si el tema está encriptado con una CMEK. Pub/Sub encripta los mensajes con claves de Google y claves administradas por Google de forma predeterminada. Si especificas esta opción, Pub/Sub usa el patrón de encriptación de sobre con CMEK. En este enfoque, Cloud KMS no encripta los mensajes. En cambio, Cloud KMS Encripta las claves de encriptación de datos (DEK) que crea Pub/Sub. para cada tema. Pub/Sub encripta los mensajes con el método DEK que se generó para el tema. Pub/Sub desencripta los mensajes de error poco antes de entregarlos a los suscriptores. Para ver más información sobre cómo crear una clave, consulta Configura la encriptación de mensajes.

Crea un tema

Crea un tema antes de publicarlo o suscribirte a él.

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."

Restricciones de las políticas de la organización

Las políticas de la organización pueden restringir la creación de temas, por ejemplo, una política puede restringir el almacenamiento de mensajes en una Compute Engine región. Para evitar errores en la creación de temas, examina y actualiza las políticas de la organización, según sea necesario, antes de crear un tema.

Si tu proyecto se creó hace poco, espera unos minutos la política de la organización para inicializar antes de crear un tema.

Ir a Políticas de la organización

Para obtener más información, consulta Configura políticas de almacenamiento de mensajes.

¿Qué sigue?

• Elige el tipo de suscripción de tu tema.

• Obtén más información para publicar un mensaje en un tema.

• Crear o modificar un tema con gcloud CLI APIs de REST o bibliotecas cliente.