Crie subscrições de obtenção

Consola

Para criar uma subscrição de obtenção, conclua os passos seguintes.

1. Na Google Cloud consola, aceda à página Subscrições.

   Aceda a Subscrições

2. Clique em Criar subscrição.

3. No campo ID da subscrição, introduza um nome.

   Para obter informações sobre como atribuir um nome a uma subscrição, consulte as Diretrizes para atribuir um nome a um tópico ou a uma subscrição.

4. Escolha ou crie um tópico no menu pendente. A subscrição recebe mensagens do tópico.
5. Mantenha o Tipo de fornecimento como Extração.
6. Mantenha todos os outros valores predefinidos.
7. Clique em Criar.

Também pode criar uma subscrição na secção Tópicos. Este atalho é útil para associar tópicos a subscrições.

1. Na Google Cloud consola, aceda à página Tópicos.

   Aceder a Tópicos

2. Clique emmore_vertjunto ao tópico no qual quer criar uma subscrição.
3. No menu de contexto, selecione Criar subscrição.

4. Introduza o ID da subscrição.

   Para obter informações sobre como atribuir um nome a uma subscrição, consulte as Diretrizes para atribuir um nome a um tópico ou a uma subscrição.

5. Mantenha o Tipo de fornecimento como Extração.
6. Mantenha todos os outros valores predefinidos.
7. Clique em Criar.

gcloud

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

2. Para criar uma subscrição de obtenção, execute o comando gcloud pubsub subscriptions create.

   gcloud pubsub subscriptions create SUBSCRIPTION_ID --topic=TOPIC_ID

   Substitua o seguinte:

   • SUBSCRIPTION_ID: o nome ou o ID da sua nova subscrição de obtenção.
   • TOPIC_ID: o nome ou o ID do seu tópico.

REST

Para criar uma subscrição de obtenção, use o método projects.subscriptions.create:

Pedido:

O pedido tem de ser autenticado com um token de acesso no cabeçalho Authorization. Para obter um token de acesso para as Credenciais padrão da aplicação atuais: gcloud auth application-default print-access-token.

PUT https://pubsub.googleapis.com/v1/projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID
Authorization: Bearer ACCESS_TOKEN

Corpo do pedido:

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

Onde:

• PROJECT_ID é o ID do seu projeto.
• SUBSCRIPTION_ID é o ID da sua subscrição.
• TOPIC_ID é o ID do tópico.

Resposta:

{
"name": "projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID",
"topic": "projects/PROJECT_ID/topics/TOPIC_ID",
"pushConfig": {},
"ackDeadlineSeconds": 10,
"messageRetentionDuration": "604800s",
"expirationPolicy": {
"ttl": "2678400s"
}
}

C++

Antes de experimentar este exemplo, siga as instruções de configuração do C++ no artigo Início rápido: usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API C++ do Pub/Sub.

namespace pubsub_admin = ::google::cloud::pubsub_admin;
namespace pubsub = ::google::cloud::pubsub;
[](pubsub_admin::SubscriptionAdminClient client,
   std::string const& project_id, std::string const& topic_id,
   std::string const& subscription_id) {
  google::pubsub::v1::Subscription request;
  request.set_name(
      pubsub::Subscription(project_id, subscription_id).FullName());
  request.set_topic(pubsub::Topic(project_id, topic_id).FullName());
  auto sub = client.CreateSubscription(request);
  if (sub.status().code() == google::cloud::StatusCode::kAlreadyExists) {
    std::cout << "The subscription already exists\n";
    return;
  }
  if (!sub) throw std::move(sub).status();

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

C#

Antes de experimentar este exemplo, siga as instruções de configuração do C# no artigo Início rápido: usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API C# do Pub/Sub.

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

public class CreateSubscriptionSample
{
    public Subscription CreateSubscription(string projectId, string topicId, string subscriptionId)
    {
        SubscriberServiceApiClient subscriber = SubscriberServiceApiClient.Create();
        TopicName topicName = TopicName.FromProjectTopic(projectId, topicId);

        SubscriptionName subscriptionName = SubscriptionName.FromProjectSubscription(projectId, subscriptionId);
        Subscription subscription = null;

        try
        {
            subscription = subscriber.CreateSubscription(subscriptionName, topicName, pushConfig: null, ackDeadlineSeconds: 60);
        }
        catch (RpcException e) when (e.Status.StatusCode == StatusCode.AlreadyExists)
        {
            // Already exists.  That's fine.
        }
        return subscription;
    }
}

Ir

O exemplo seguinte usa a versão principal da biblioteca de cliente Go Pub/Sub (v2). Se ainda estiver a usar a biblioteca v1, consulte o guia de migração para a v2. Para ver uma lista de exemplos de código da v1, consulte os exemplos de código descontinuados.

Antes de experimentar este exemplo, siga as instruções de configuração do Go em Início rápido: usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API Go Pub/Sub.

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/pubsub/v2"
	"cloud.google.com/go/pubsub/v2/apiv1/pubsubpb"
)

func create(w io.Writer, projectID, topic, subscription string) error {