Questa pagina è stata tradotta dall'API Cloud Translation.

Crea un argomento

All'interno di Pub/Sub, un argomento è una risorsa denominata che rappresenta un feed di messaggi. Devi creare un argomento prima di poterlo pubblicare o iscriverti. 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 relativa terminologia.
Scopri di più sulla procedura di pubblicazione.

Ruoli e autorizzazioni richiesti per gestire gli argomenti

Per ottenere le autorizzazioni necessarie per creare e gestire gli argomenti, chiedi all'amministratore di concederti il ruolo IAM Editor Pub/Sub (roles/pubsub.editor) nel progetto o nell'argomento. Per saperne di più sulla concessione dei ruoli, consulta Gestire l'accesso a progetti, cartelle e organizzazioni.

Questo ruolo predefinito contiene le autorizzazioni necessarie per creare e gestire gli argomenti. Per vedere le autorizzazioni esatte obbligatorie, espandi la sezione Autorizzazioni obbligatorie:

Autorizzazioni obbligatorie

Per creare e gestire gli argomenti sono necessarie le seguenti autorizzazioni:

Crea un argomento: pubsub.topics.create
Eliminare un argomento: pubsub.topics.delete
Scollegare una sottoscrizione da un argomento: pubsub.topics.detachSubscription
Ricevi un argomento: pubsub.topics.get
Elenca un argomento: pubsub.topics.list
Pubblica in un argomento: pubsub.topics.publish
Aggiorna un argomento: pubsub.topics.update
Ottieni il criterio IAM per un argomento: pubsub.topics.getIamPolicy
Configura il criterio IAM per un argomento: pubsub.topics.setIamPolicy

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 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 sua creazione. La sottoscrizione predefinita 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 di ripetizione immediata

Utilizza uno schema

Uno schema è un formato che il campo dei dati del messaggio deve seguire. Uno schema è un contratto tra il publisher e l'abbonato che viene applicato in modo forzato Pub/Sub. Gli schemi di argomenti contribuiscono a standardizzare i tipi di messaggi e le autorizzazioni in modo che possano essere utilizzati da diversi team della tua organizzazione. Pub/Sub crea un'autorità centrale per i tipi di messaggi e le autorizzazioni. Per creare un argomento con uno schema: consulta la sezione Panoramica dello schema.

Abilita importazione

Se abiliti questa proprietà, puoi importare flussi di dati da fonti esterne a un argomento, in modo da poter utilizzare tutte le funzionalità di Google Cloud. Per creare un argomento di importazione per per l'importazione, consulta Creare un argomento di importazione.

Attiva conservazione messaggi

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

Valore predefinito: 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 sottoscrittore separato di alto profilo. Per ulteriori informazioni sulle sottoscrizioni BigQuery, consulta Sottoscrizioni BigQuery.

Esporta i dati dei messaggi in Cloud Storage

Se abiliti questa proprietà, puoi creare un'istanza Cloud Storage che scrive i messaggi in un ambiente Cloud Storage esistente tabella non appena vengono ricevuti. Non è necessario configurare un sottoscrittore separato di alto profilo. Per ulteriori informazioni sugli abbonamenti a Cloud Storage, consulta Abbonamenti a Cloud Storage.

Chiave di crittografia gestita da Google

Specifica che l'argomento è criptato tramite chiavi di crittografia gestite da Google. Per impostazione predefinita, Pub/Sub cripta i messaggi con le chiavi gestite da Google, pertanto 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ù avanzata disponibile. Questa opzione non richiede ulteriore configurazione. Per saperne di più sulla crittografia gestita da Google consulta l'articolo Crittografia predefinita con chiavi di proprietà di Google e gestite da Google.

Chiave Cloud KMS

Specifica se l'argomento è criptato con una chiave di crittografia gestita dal cliente (CMEK). Pub/Sub cripta i messaggi con chiavi di proprietà di Google e gestite da Google per impostazione predefinita. Se specifichi questa opzione, Pub/Sub utilizza il pattern di crittografia dell'involucro con CMEK. In questo approccio, Cloud KMS non cripta i messaggi. Invece, Cloud KMS cripta le chiavi di crittografia DEK (Data Encryption Key) che Pub/Sub 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 ulteriori informazioni sulla creazione di una chiave, vedi Configurare la crittografia dei messaggi.

crea un argomento

Crea un argomento prima di pubblicarlo o abbonarti.

Console

Per creare un argomento:

Nella console Google Cloud, vai alla pagina Argomenti di Pub/Sub.

Vai ad Argomenti
Fai clic su Crea argomento.
Nel campo ID argomento, inserisci un ID per l'argomento. Per ulteriori informazioni sull'assegnazione dei nomi agli argomenti, consulta le linee guida per l'assegnazione dei nomi.
Mantieni l'opzione Aggiungi una sottoscrizione predefinita.
Facoltativo. Non selezionare le altre opzioni.
Fai clic su Crea argomento.

gcloud

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.
Per creare un argomento, esegui il comando gcloud pubsub topics create:
```
gcloud pubsub topics create TOPIC_ID
```

REST

Per creare un argomento, utilizza projects.topics.create :

La richiesta deve essere autenticata con un token di accesso nel Intestazione Authorization. Per ottenere un token di accesso per le Credenziali predefinite dell'applicazione correnti: gcloud auth application-default print-access-token.

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

Dove:

PROJECT_ID è l'ID progetto.

TOPIC_ID è il tuo ID argomento.

Risposta:

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

C++

Prima di provare questo esempio, segui le istruzioni di configurazione di C++ riportate nella guida rapida di Pub/Sub che utilizza le librerie client. Per ulteriori informazioni, consulta API Pub/Sub C++ documentazione di riferimento.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per un ambiente di sviluppo locale.

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";
}

C#

Prima di provare questo esempio, segui le istruzioni per la configurazione di C# nel Guida rapida di Pub/Sub con librerie client. Per ulteriori informazioni, consulta API Pub/Sub C# documentazione di riferimento.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per un ambiente di sviluppo locale.


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;
    }
}

Go

Prima di provare questo esempio, segui le istruzioni di configurazione di Go riportate nella guida rapida di Pub/Sub che utilizza le librerie client. Per ulteriori informazioni, consulta API Pub/Sub Go documentazione di riferimento.

Per eseguire l'autenticazione su Pub/Sub, configura le credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per un ambiente di sviluppo locale.

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
}

Java

Prima di provare questo esempio, segui le istruzioni di configurazione di Java riportate nella guida rapida di Pub/Sub che utilizza le librerie client. Per ulteriori informazioni, consulta API Pub/Sub Java documentazione di riferimento.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per ulteriori informazioni, vedi Configura l'autenticazione per un ambiente di sviluppo locale.


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

Node.js

/**
 * 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.`);
}

Node.js

/**
 * 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.`);
}

PHP

Prima di provare questo esempio, segui le istruzioni per la configurazione di PHP nel Guida rapida di Pub/Sub con librerie client. Per ulteriori informazioni, consulta API Pub/Sub PHP documentazione di riferimento.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per un ambiente di sviluppo locale.

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

Python

Prima di provare questo esempio, segui le istruzioni di configurazione di Python riportate nella guida rapida di Pub/Sub che utilizza le librerie client. Per ulteriori informazioni, consulta API Pub/Sub Python documentazione di riferimento.

Per autenticarti a Pub/Sub, configura le credenziali predefinite dell'applicazione. Per ulteriori informazioni, vedi Configura l'autenticazione per un ambiente di sviluppo locale.

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}")

Ruby

Prima di provare questo esempio, segui le istruzioni per la configurazione di Ruby nel Guida rapida di Pub/Sub con librerie client. Per ulteriori informazioni, consulta API Pub/Sub Ruby documentazione di riferimento.

Per eseguire l'autenticazione su Pub/Sub, configura le credenziali predefinite dell'applicazione. Per ulteriori informazioni, vedi Configura l'autenticazione per un ambiente di sviluppo locale.

# 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

I criteri dell'organizzazione possono limitare la creazione di argomenti, ad esempio: un criterio può limitare l'archiviazione dei messaggi regione. Per evitare errori di creazione degli argomenti, esamina e aggiorna dell'organizzazione, se necessario, prima di creare un argomento.

Se il progetto è stato appena creato, attendi qualche minuto il criterio dell'organizzazione da inizializzare prima di creare un argomento.

Vai a Criteri dell'organizzazione

Per ulteriori informazioni, vedi Configurare i criteri di archiviazione dei messaggi.

Passaggi successivi

Scegli il tipo di sottoscrizione per l'argomento.
Scopri come pubblicare un messaggio in un argomento.
Crea o modifica un argomento con gcloud CLI, API REST o librerie client.