Crea un argomento

In Pub/Sub, un argomento è una risorsa denominata che rappresenta un feed di messaggi. Devi creare un argomento prima di poterlo pubblicare o sottoscrivere. Pub/Sub supporta due tipi di argomenti: un argomento standard e un argomento di importazione.

Questo documento descrive come creare un argomento Pub/Sub standard. Se vuoi saperne di più su un argomento di importazione e su come crearne uno, consulta Informazioni sugli argomenti di importazione.

Per creare un argomento, puoi utilizzare la console Google Cloud , Google Cloud CLI, la libreria client o l'API Pub/Sub.

Prima di iniziare

• Scopri di più sul servizio Pub/Sub e sulla sua terminologia.

• Scopri di più sulla procedura di pubblicazione.

Ruoli e autorizzazioni richiesti

Per ottenere le autorizzazioni necessarie per creare un argomento, chiedi all'amministratore di concederti il ruolo IAM Editor Pub/Sub(roles/pubsub.editor) nel progetto. Per saperne di più sull'assegnazione dei ruoli, consulta Gestisci l'accesso a progetti, cartelle e organizzazioni.

Questo ruolo predefinito contiene le autorizzazioni necessarie per creare un argomento. Per vedere quali sono esattamente le autorizzazioni richieste, espandi la sezione Autorizzazioni obbligatorie:

Potresti anche ottenere queste autorizzazioni con ruoli personalizzati o altri ruoli predefiniti.

Puoi configurare il controllo dell'accesso a livello di progetto e a livello di singola risorsa. Puoi creare una sottoscrizione in un progetto e collegarla a un argomento che si trova in un altro progetto. Assicurati di disporre delle autorizzazioni necessarie per ogni progetto.

Proprietà di un argomento

Quando crei o aggiorni un argomento, devi specificarne le proprietà.

Aggiungi una sottoscrizione predefinita

Aggiunge una sottoscrizione predefinita all'argomento Pub/Sub. Puoi creare un'altra sottoscrizione per l'argomento dopo la creazione. L'abbonamento predefinito ha le seguenti proprietà:

• ID abbonamento di -sub
• Tipo di distribuzione pull
• Durata di conservazione dei messaggi di sette giorni
• Scadenza dopo 31 giorni di inattività
• Scadenza conferma di 10 secondi
• Criterio immediato per nuovi tentativi

Utilizza uno schema

Uno schema è un formato che il campo dati del messaggio deve seguire. Uno schema è un contratto tra il publisher e l'abbonato che Pub/Sub applica. Gli schemi degli argomenti contribuiscono a standardizzare i tipi di messaggi e le autorizzazioni per consentire a diversi team dell'organizzazione di utilizzarli. Pub/Sub crea un'autorità centrale per i tipi di messaggi e le autorizzazioni. Per creare un argomento con schema, consulta la Panoramica dello schema.

Abilita importazione

L'attivazione di questa proprietà consente di importare flussi di dati da origini esterne in un argomento in modo da poter utilizzare le funzionalità di Google Cloud. Per creare un argomento di importazione per l'inserimento, vedi quanto segue:

• Crea un argomento di importazione Amazon Kinesis Data Streams

• Crea un argomento di importazione di Cloud Storage

• Crea un argomento Azure Event Hubs

• Crea un argomento Amazon MSK

• Crea un argomento Confluent Cloud

Attiva conservazione messaggi

Specifica per quanto tempo l'argomento Pub/Sub conserva i messaggi dopo la pubblicazione. Al termine del periodo di conservazione dei messaggi, Pub/Sub potrebbe eliminare il messaggio indipendentemente dal suo stato di riconoscimento. Vengono addebitate le tariffe di archiviazione dei messaggi per l'archiviazione di tutti i messaggi pubblicati nell'argomento

• Impostazione predefinita = Non abilitato
• Valore minimo = 10 minuti
• Valore massimo = 31 giorni

Esporta i dati dei messaggi in BigQuery

L'attivazione di questa proprietà consente di creare una sottoscrizione BigQuery che scrive i messaggi in una tabella BigQuery esistente non appena vengono ricevuti. Non è necessario configurare un client abbonato separato. Per ulteriori informazioni sulle sottoscrizioni BigQuery, vedi Sottoscrizioni BigQuery.

Esegui il backup dei dati dei messaggi in Cloud Storage

L'attivazione di questa proprietà consente di creare una sottoscrizione Cloud Storage che scrive i messaggi in una tabella Cloud Storage esistente quando vengono ricevuti. Non è necessario configurare un client abbonato separato. Per saperne di più sulle sottoscrizioni Cloud Storage, consulta Sottoscrizioni Cloud Storage.

Trasformazioni

Le SMT degli argomenti consentono modifiche leggere ai dati e agli attributi dei messaggi direttamente in Pub/Sub. Questa funzionalità consente la pulizia, il filtraggio o la conversione del formato dei dati prima che i messaggi vengano pubblicati nell'argomento.

Per saperne di più sulle trasformazioni SMT, consulta la panoramica delle trasformazioni SMT.

Google-owned and Google-managed encryption key

Specifica che l'argomento è criptato utilizzando Google-owned and Google-managed encryption keys. Pub/Sub cripta i messaggi con Google-owned and Google-managed encryption keys per impostazione predefinita, quindi la scelta di questa opzione mantiene il comportamento predefinito. Google gestisce automaticamente la gestione e la rotazione delle chiavi, garantendo che i tuoi messaggi siano sempre protetti con la crittografia più efficace disponibile. Questa opzione non richiede ulteriori configurazioni. Per maggiori informazioni su Google-owned and Google-managed encryption keys, consulta Crittografia predefinita con Google-owned and Google-managed encryption keys.

Chiave Cloud KMS

Specifica se l'argomento è criptato con una chiave di crittografia gestita dal cliente (CMEK). Pub/Sub cripta i messaggi con Google-owned and Google-managed encryption keys per impostazione predefinita. Se specifichi questa opzione, Pub/Sub utilizza il pattern di crittografia envelope con CMEK. Con questo approccio, Cloud KMS non cripta i messaggi. Cloud KMS cripta invece le chiavi di crittografia dei dati (DEK) che Pub/Sub crea per ogni argomento. Pub/Sub cripta i messaggi utilizzando la DEK più recente generata per l'argomento. Pub/Sub decripta i messaggi poco prima che vengano consegnati ai sottoscrittori. Per saperne di più sulla creazione di una chiave, vedi Configurare la crittografia dei messaggi.

Crea un argomento

Crea un argomento prima di poterlo pubblicare o sottoscrivere.

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/v2"
	"cloud.google.com/go/pubsub/v2/apiv1/pubsubpb"
)

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

	topic := &pubsubpb.Topic{
		Name: fmt.Sprintf("projects/%s/topics/%s", projectID, topicID),
	}
	t, err := client.TopicAdminClient.CreateTopic(ctx, topic)
	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."

Vincoli dei criteri dell'organizzazione

Le policy dell'organizzazione possono limitare la creazione di argomenti, ad esempio, una policy può limitare l'archiviazione dei messaggi in una regione Compute Engine. Per evitare errori di creazione degli argomenti, esamina e aggiorna le policy dell'organizzazione, se necessario, prima di creare un argomento.

Se il progetto è stato creato di recente, attendi qualche minuto per l'inizializzazione del criterio dell'organizzazione prima di creare un argomento.

Vai a Policy dell'organizzazione

Per saperne di più, consulta Configurare le norme di archiviazione dei messaggi.

Passaggi successivi

• Scegli il tipo di abbonamento per l'argomento.

• Scopri come pubblicare un messaggio in un argomento.

• Risolvi i problemi relativi a un argomento.

• Crea o modifica un argomento con gcloud CLI, API REST o librerie client.