Créer un sujet

Dans Pub/Sub, un sujet est une ressource nommée qui représente un flux de messages. Vous devez créer un sujet avant de pouvoir publier ou vous abonner avec lui. Pub/Sub prend en charge deux types de sujets: un sujet standard et un sujet d'importation.

Ce document explique comment créer un sujet standard Pub/Sub. Si que vous souhaitez en savoir plus sur un sujet d'importation et sur la façon d'en créer un, consultez Créez un sujet d'importation.

Pour créer un sujet, vous pouvez utiliser la console Google Cloud, la Google Cloud CLI, la bibliothèque cliente ou l'API Pub/Sub.

Avant de commencer

• Découvrez le service Pub/Sub et sa terminologie.

• En savoir plus sur le processus de publication

Rôles et autorisations requis pour gérer les sujets

Pour obtenir les autorisations nécessaires pour créer et gérer des sujets, demandez à votre administrateur de vous accorder le Éditeur Pub/Sub(roles/pubsub.editor) un rôle IAM sur votre sujet ou projet. Pour en savoir plus sur l'attribution de rôles, consultez la section Gérer les accès.

Ce rôle prédéfini contient les autorisations requises pour créer et gérer des sujets. Pour connaître les autorisations exactes requises, développez la section Autorisations requises :

Vous pouvez également obtenir ces autorisations avec des rôles personnalisés ou d'autres rôles prédéfinis.

Vous pouvez configurer le contrôle des accès au niveau du projet et au niveau au niveau des ressources. Vous pouvez créer un abonnement dans un projet à un sujet situé dans un autre projet. Assurez-vous de disposer des autorisations requises pour chaque projet.

Propriétés d'un sujet

Lorsque vous créez ou mettez à jour un sujet, vous devez spécifier ses propriétés.

• Ajoutez un abonnement par défaut. Ajoute un abonnement par défaut au sujet Pub/Sub. Vous pouvez créer un autre abonnement pour le sujet après sa création. L'abonnement par défaut dispose du les propriétés suivantes:

  • ID d'abonnement de -sub
  • Type de distribution : pull
  • Durée de conservation des messages de sept jours
  • Expiration après 31 jours d'inactivité
  • Délai d'accusé de réception de 10 secondes
  • Stratégie de nouvelle tentative : immédiate
• Schéma. Un schéma est un format dans lequel le champ de données du message doit suivre. Un schéma est un contrat conclu entre l'éditeur et l'abonné appliqué par Pub/Sub. Les schémas de sujet permettent de standardiser et les autorisations nécessaires pour être utilisés par différents types les équipes de votre organisation. Pub/Sub crée une passerelle concernant les types de messages et les autorisations. Pour créer un sujet avec consultez la page Présentation du schéma.

• Activez l'ingestion. L'activation de cette propriété vous permet ingérer des flux de données provenant de sources externes dans un sujet peuvent exploiter les fonctionnalités de Google Cloud. Créer un sujet d'importation pour l'ingestion, consultez Créer un sujet d'importation.

• Durée de conservation des messages. Spécifie la durée pendant laquelle Le sujet Pub/Sub conserve les messages après leur publication. Après le la durée de conservation des messages est terminée, Pub/Sub peut supprimer quel que soit son état d'accusé de réception. Frais de stockage des messages sont facturés pour le stockage de tous les messages publiés dans le sujet.

  • Par défaut = Non activé
  • Valeur minimale = 10 minutes
  • Valeur maximale = 31 jours
• Utilisez une clé de chiffrement gérée par le client (CMEK). Indique si le sujet est chiffré avec une clé CMEK. Pub/Sub chiffre les messages avec des clés appartenant ou gérées par Google par défaut. Si vous spécifiez cette option, Pub/Sub utilise le modèle de chiffrement encapsulé avec une clé CMEK. Dans cette approche, Cloud KMS ne chiffre pas les messages. À la place, Cloud KMS chiffre les clés de chiffrement de données (DEK) créées par Pub/Sub ; pour chaque thème. Pub/Sub chiffre les messages à l'aide de la dernière version DEK générée pour le sujet. Pub/Sub déchiffre messages peu avant leur distribution aux abonnés. Pour plus sur la création d'une clé, consultez Configurer le chiffrement des messages

Créer un sujet

Créez un sujet avant de pouvoir le publier ou vous y abonner.

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

Contraintes liées aux règles d'administration

Les règles d'administration peuvent restreindre la création de sujets, par exemple une règle peut restreindre le stockage des messages dans la même région. Pour éviter les erreurs de création de sujet, examinez et mettez à jour des règles d'administration, selon les besoins, avant de créer un sujet.

Si vous venez de créer votre projet, attendez quelques minutes que la règle d'administration doit s'initialiser avant de créer un sujet.

Accéder à la page Règles d'administration

Pour en savoir plus, consultez Configurer les règles de stockage des messages.

Étape suivante

• Choisissez le type d'abonnement à votre sujet.

• Découvrez comment publier un message dans un sujet.

• créer ou modifier un sujet avec la gcloud CLI ; API REST ou bibliothèques clientes.