Repetir uma mensagem no Pub/Sub buscando um snapshot ou um carimbo de data/hora
O Pub/Sub não consegue recuperar as mensagens depois que elas são confirmadas. No entanto, às vezes, pode ser necessário repetir as mensagens confirmadas, por exemplo, se você fez uma confirmação errada. Em seguida, use o recurso Busca para marcar mensagens confirmadas anteriormente como não confirmadas e forçar o Pub/Sub a reenviar essas mensagens. Você também pode usar a busca para excluir as mensagens não confirmadas mudando o estado delas para confirmadas.
Procure um snapshot ou um carimbo de data/hora para reproduzir as mensagens em uma assinatura. Neste guia, mostramos exemplos de como repetir mensagens do Pub/Sub confirmadas anteriormente usando a busca.
Para seguir as instruções detalhadas desta tarefa diretamente no console do Google Cloud, clique em Orientação:
Antes de começar
- Faça login na sua conta do Google Cloud. Se você começou a usar o Google Cloud agora, crie uma conta para avaliar o desempenho de nossos produtos em situações reais. Clientes novos também recebem US$ 300 em créditos para executar, testar e implantar cargas de trabalho.
-
Configurar um projeto do Google Cloud.
Clique para:
- Crie ou selecione um projeto.
- ativar a API Pub/Sub para esse projeto;
É possível visualizar e gerenciar esses recursos a qualquer momento no Console do Google Cloud.
- Instale a CLI do Google Cloud.
-
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init
-
Configurar um projeto do Google Cloud.
Clique para:
- Crie ou selecione um projeto.
- ativar a API Pub/Sub para esse projeto;
É possível visualizar e gerenciar esses recursos a qualquer momento no Console do Google Cloud.
- Instale a CLI do Google Cloud.
-
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init
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 que acompanha 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 padrão do Debian. 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 gcloud do Pub/Sub.
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)
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
É possível criar snapshots ou buscar 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 console do Google Cloud, 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.
É possível visualizar os snapshots na página "Snapshots" no console do Google Cloud. 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 console do Google Cloud, 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?
Os recursos e links extras estão disponíveis na página de suporte do Pub/Sub.
A seguir
Consulte Como repetir e descartar mensagens.