Tópicos de mensagens não entregues

Os subscritores podem não conseguir processar mensagens por vários motivos. Por exemplo, podem existir problemas transitórios na obtenção dos dados necessários para processar uma mensagem. Em alternativa, uma mensagem pode estar num formato que o subscritor não espera.

Para gerir mensagens com impossibilidade de entrega que os subscritores não conseguem confirmar, o Pub/Sub pode encaminhá-las para um tópico de mensagens não entregues (também conhecido como uma fila de mensagens não entregues).

Antes de começar

• Crie um tópico para a configuração do tópico de mensagens não entregues.

  Em alternativa, se seguir todas as instruções nesta página de forma integral, pode criar o tópico num passo subsequente.

Funções necessárias

Para receber as autorizações de que precisa para gerir tópicos e subscrições, peça ao seu administrador que lhe conceda a função IAM Editor do Pub/Sub (roles/pubsub.editor) no seu projeto. Para mais informações sobre a atribuição de funções, consulte o artigo Faça a gestão do acesso a projetos, pastas e organizações.

Também pode conseguir as autorizações necessárias através de funções personalizadas ou outras funções predefinidas.

Pode configurar o controlo de acesso ao nível do projeto e ao nível do recurso individual. Pode criar uma subscrição num projeto e anexá-la a um tópico localizado num projeto diferente. Certifique-se de que tem as autorizações necessárias para cada projeto.

Como funcionam os tópicos de mensagens não entregues

Quando uma aplicação subscritora não consegue acusar a receção de uma mensagem, o Pub/Sub repete a entrega até que o prazo de acusação de receção seja cumprido ou a mensagem expire. Após um número de tentativas de entrega configurado aproximadamente, o Pub/Sub pode encaminhar a mensagem não entregável para um tópico de mensagens rejeitadas.

Quando o Pub/Sub encaminha uma mensagem não entregável, envolve a mensagem original numa nova e adiciona atributos que identificam a subscrição de origem. Em seguida, a mensagem é enviada para o tópico de mensagens não entregues especificado. Uma subscrição separada anexada ao tópico de mensagens não entregues pode, então, receber estas mensagens encaminhadas para análise e depuração offline.

Como são calculadas as tentativas de entrega máximas

O Pub/Sub só contabiliza as tentativas de entrega quando um tópico de mensagens não entregues está configurado corretamente e inclui as autorizações IAM corretas.

O número máximo de tentativas de entrega é aproximado porque o Pub/Sub encaminha mensagens não entregáveis com base no melhor esforço possível. O serviço pode encaminhar uma mensagem após menos tentativas do que o configurado ou pode tentar a entrega mais algumas vezes antes de encaminhar.

O número monitorizado de tentativas de entrega de uma mensagem também pode ser reposto para zero, especialmente para uma subscrição de obtenção com subscritores inativos. Como resultado, as mensagens podem ser entregues ao cliente subscritor mais vezes do que o número máximo de tentativas de entrega configurado.

Propriedades do tópico de mensagens não entregues

Pode definir as seguintes propriedades de subscrição num tópico de mensagens não entregues.

• Número máximo de tentativas de entrega: um valor numérico que indica o número de tentativas de entrega que o Pub/Sub faz para uma mensagem específica. Se o cliente subscritor não conseguir acusar a receção da mensagem dentro do número configurado de tentativas de entrega, a mensagem é encaminhada para um tópico de mensagens não entregues.

  • Valor predefinido = 5
  • Valor máximo = 100
  • Valor mínimo = 5

• Projeto com o tópico de mensagens não entregues: se o tópico de mensagens não entregues estiver num projeto diferente da subscrição, tem de especificar o projeto com o tópico de mensagens não entregues. Defina o tópico de mensagens não entregues para um tópico diferente do tópico ao qual a subscrição está associada.

Configure um tópico de mensagens não entregues

Os passos seguintes descrevem o fluxo de trabalho para usar tópicos de mensagens não entregues.

1. Crie um tópico (para usar como um tópico de mensagens não entregues).

2. Crie uma subscrição para o seu tópico de mensagens não entregues.

3. Ative a indicação de teclas mortas na sua subscrição.

4. Anexe o tópico que criou anteriormente à sua subscrição.

5. Conceda as funções necessárias para usar tópicos de mensagens não entregues à sua conta de serviço do Pub/Sub.

Crie um tópico para usar com tópicos de mensagens não entregues

Se já criou um tópico para usar na sua subscrição, pode ignorar este passo.

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

   Aceder a Tópicos

2. Clique em Criar tópico.

3. Introduza um ID do tópico, por exemplo, my-test-topic.

4. Mantenha a opção da subscrição predefinida e clique em Criar.

Defina um tópico de mensagens não entregues numa subscrição

Pode definir um tópico de mensagens não entregues numa nova subscrição ou numa subscrição existente.

Defina um tópico de mensagens não entregues numa nova subscrição

Pode criar uma subscrição e definir um tópico de mensagens não entregues através da Google Cloud consola, da CLI do Google Cloud, das bibliotecas cliente ou da API Pub/Sub.

gcloud pubsub subscriptions create subscription-id \
  --topic=topic-id \
  --dead-letter-topic=dead-letter-topic-name \
  [--max-delivery-attempts=max-delivery-attempts] \
  [--dead-letter-topic-project=dead-letter-topic-project]

namespace pubsub = ::google::cloud::pubsub;
namespace pubsub_admin = ::google::cloud::pubsub_admin;
[](pubsub_admin::SubscriptionAdminClient client,
   std::string const& project_id, std::string const& topic_id,
   std::string const& subscription_id,
   std::string const& dead_letter_topic_id,
   int dead_letter_delivery_attempts) {
  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());
  request.mutable_dead_letter_policy()->set_dead_letter_topic(
      pubsub::Topic(project_id, dead_letter_topic_id).FullName());
  request.mutable_dead_letter_policy()->set_max_delivery_attempts(
      dead_letter_delivery_attempts);
  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