Reproduzir uma mensagem no Pub/Sub buscando um snapshot ou carimbo de data/hora
O Pub/Sub não pode recuperar as mensagens depois que você as confirma. No entanto, às vezes, é necessário reproduzir as mensagens confirmadas, por exemplo, se você fez uma confirmação incorreta. Em seguida, use o recurso de busca para marcar as mensagens confirmadas anteriormente como não confirmadas e forçar o Pub/Sub a reenviar essas mensagens. Também é possível usar a busca para excluir as mensagens não confirmadas, mudando o estado delas para confirmado.
Busque um snapshot ou um carimbo de data/hora para reproduzir as mensagens em uma assinatura. Este guia mostra exemplos de como reproduzir mensagens do Pub/Sub confirmadas anteriormente usando a busca.
Para seguir as instruções detalhadas desta tarefa diretamente no Google Cloud console, clique em Orientação:
Antes de começar
Conclua as etapas a seguir antes de executar o pipeline.
Criar o projeto
- Faça login na sua Google Cloud conta do. Se você começou a usar o Google Cloud, crie uma conta para avaliar o desempenho dos nossos produtos em situações reais. Clientes novos também recebem US $300 em créditos para executar, testar e implantar cargas de trabalho.
Set up a Google Cloud console project.
Click to:
- Create or select a project.
- Enable the Pub/Sub API for that project.
You can view and manage these resources at any time in the Google Cloud console.
-
Instale a Google Cloud CLI.
-
Ao usar um provedor de identidade (IdP) externo, primeiro faça login na gcloud CLI com sua identidade federada.
-
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init Set up a Google Cloud console project.
Click to:
- Create or select a project.
- Enable the Pub/Sub API for that project.
You can view and manage these resources at any time in the Google Cloud console.
-
Instale a Google Cloud CLI.
-
Ao usar um provedor de identidade (IdP) externo, primeiro faça login na gcloud CLI com sua identidade federada.
-
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init
Funções exigidas
Para concluir este guia de início rápido, você precisa das seguintes funções do Identity and Access Management (IAM).
Para conseguir as permissões necessárias a fim de concluir o guia de início rápido, peça ao administrador para conceder a você os seguintes papéis do IAM no projeto:
-
Administrador do Service Usage (
roles/serviceusage.serviceUsageAdmin) -
Editor do Pub/Sub (
roles/pubsub.editor)
Para mais informações sobre a concessão de papéis, consulte Gerenciar o acesso a projetos, pastas e organizações.
Também é possível conseguir as permissões necessárias usando personalizados papéis ou outros predefinidos papéis.
Como usar a interface de linha de comando gcloud
A maneira mais fácil de usar a gcloud é no Cloud Shell . Também é possível usar a ferramenta de linha de comando fornecida com a Google Cloud CLI. Os pré-requisitos de configuração serão atendidos automaticamente para a CLI gcloud se você criar uma nova instância de máquina do Compute Engine com escopos de acesso, incluindo todas as APIs do Cloud e a imagem do Debian padrão. A maneira mais simples de criá-la é por meio da IU do Compute Engine. No restante deste documento, vamos supor que você esteja usando uma dessas ferramentas de linha de comando.
Para mais informações sobre como usar a gcloud, consulte o guia de início rápido da gcloud.
Veja também a seção sobre gcloud pubsub na
referência da gcloud
para uma lista completa de comandos do Pub/Sub gcloud.
Criar e buscar snapshots
Crie um tópico e uma assinatura. Para ter melhor interatividade, use um prazo de confirmação curto:
gcloud pubsub topics create seek-demo-topic gcloud pubsub subscriptions create seek-demo-sub --topic=seek-demo-topic --ack-deadline=10
Até o momento, nenhuma mensagem na assinatura foi confirmada. Capture esse estado criando um instantâneo:
gcloud pubsub snapshots create my-snapshot --subscription=seek-demo-sub gcloud pubsub snapshots list
Agora publique, efetue pull e confirme uma mensagem:
gcloud pubsub topics publish seek-demo-topic --message 'hello, world' gcloud pubsub subscriptions pull --auto-ack seek-demo-sub
Observe que os pulls subsequentes não produzem novas mensagens (mas podem gerar algumas duplicatas transitórias):
gcloud pubsub subscriptions pull --auto-ack seek-demo-sub
É possível recuperar a mensagem buscando a assinatura do instantâneo. Talvez a mensagem não seja entregue instantaneamente porque o Pub/Sub não garante a latência de entrega de mensagens. No entanto, é certo que as mensagens retidas no instantâneo serão entregues pelo menos uma vez:
gcloud pubsub subscriptions seek seek-demo-sub --snapshot=my-snapshot gcloud pubsub subscriptions pull seek-demo-sub --auto-ack
É possível buscar outras assinaturas do mesmo snapshot, desde que o tópico da assinatura seja igual ao do snapshot:
gcloud pubsub subscriptions create seek-demo-sub2 --topic=seek-demo-topic --ack-deadline=10 gcloud pubsub subscriptions seek seek-demo-sub2 --snapshot=my-snapshot
Fazer pull de seek-demo-sub2 agora produzirá mensagens que foram publicadas antes da criação de seek-demo-sub2:
gcloud pubsub subscriptions pull seek-demo-sub2 --auto-ack
Quando você terminar de utilizar o snapshot, faça a limpeza:
gcloud pubsub snapshots delete my-snapshot
Buscar um carimbo de data/hora
Outra maneira de repetir mensagens que foram confirmadas é buscar um carimbo de data/hora. Para isso, primeiro configure a assinatura para reter as mensagens confirmadas usando retain-acked-messages. Se retain-acked-messages estiver definido, o Pub/Sub retém as mensagens confirmadas por sete dias.
Só é necessário executar esta etapa caso pretenda buscar um carimbo de data/hora, e não um snapshot.
gcloud pubsub subscriptions update seek-demo-sub --retain-acked-messages
Agora publique, efetue pull e confirme uma mensagem:
gcloud pubsub topics publish seek-demo-topic --message 'hello, world' gcloud pubsub subscriptions pull --auto-ack seek-demo-sub
O próximo pull não pode retornar nenhuma mensagem:
gcloud pubsub subscriptions pull seek-demo-sub
Agora, busque a assinatura no histórico para recuperar a mensagem. Observe que as sinalizações aritméticas de data diferem entre as versões GNU e BSD (MacOS) do comando date:
export TS_FORMAT=%Y-%m-%dT%H:%M:%SZ gcloud pubsub subscriptions seek seek-demo-sub --time=$(date -u -d '-10 min' +$TS_FORMAT)
Para mais informações sobre formatos de tempo compatíveis, consulte Data e hora no gcloud.
Um pull subsequente produz a mensagem novamente:
gcloud pubsub subscriptions pull --auto-ack seek-demo-sub
É possível também usar a busca para pular a entrega de todas as mensagens publicadas antes de um determinado momento, como a hora atual. Para fazer isso, busque a assinatura da hora atual para marcar como confirmadas todas as mensagens anteriores:
gcloud pubsub topics publish seek-demo-topic --message 'hello, world' gcloud pubsub subscriptions seek seek-demo-sub --time=$(date -u +$TS_FORMAT)
Um atraso na propagação de cerca de 60 segundos significa que a mensagem não será mais entregue. Verifique isso executando repetidamente o comando pull sem confirmar a mensagem:
gcloud pubsub subscriptions pull seek-demo-sub
Use o Console do Cloud
Crie snapshots ou busque snapshots atuais na página de detalhes da assinatura do Console do Cloud. Para regras de nomenclatura de snapshots, consulte Nomes de recursos.
Criar um instantâneo
No Google Cloud console, acesse a página Assinaturas do Pub/Sub.
Selecione uma assinatura na lista.
Clique em Criar snapshot.
Insira um ID para o snapshot e clique em Criar para salvar.
Os snapshots podem ser visualizados na página de snapshots no Google Cloud console. Também é possível gerenciar snapshots na página de detalhes de um tópico individual.
Como repetir uma assinatura
Na caixa de diálogo Repetir mensagens, é possível buscar um momento anterior ou um snapshot salvo. Para abrir a caixa de diálogo, faça o seguinte:
No Google Cloud console, acesse a página Assinaturas do Pub/Sub.
Selecione uma assinatura na lista.
Clique em Repetir mensagens.
Em Procurar, selecione Para um ponto anterior no tempo ou Para um snapshot e escolha o momento ou snapshot que será buscado.
Clique em Procurar para repetir as mensagens.
Como foi?
Observe que recursos e links adicionais estão disponíveis na página de suporte do Pub/Sub.
A seguir
Consulte Como repetir e descartar mensagens.