Depois que você confirma as mensagens no Pub/Sub, elas se tornam fica inacessível para o cliente assinante. Além disso, os clientes assinantes precisam processar todas as mensagens de uma assinatura, mesmo que apenas um subconjunto seja necessário.
O recurso seek estende a capacidade dos assinantes ao permitindo que você altere o estado de confirmação de mensagens em massa. Por exemplo, é possível repetir mensagens confirmadas anteriormente ou limpá-las em massa. Além disso, é possível copiar o estado de confirmação de uma assinatura para outro usando a busca em combinação com um snapshot.
Para uma demonstração rápida de como esses recursos funcionam, consulte reproduza uma mensagem no Pub/Sub buscando um snapshot ou carimbo de data/hora.
Visão geral do snapshot e da busca
Um snapshot do Pub/Sub é uma visualização pontual, consistente e confiável do estado de confirmação de mensagem (ACK) de uma assinatura. Um snapshot registra o estado de confirmação de todas as mensagens em uma assinatura no momento da criação. Um snapshot mantém mensagens não confirmadas da assinatura de origem no momento da criação de o snapshot e as mensagens publicadas no tópico após o snapshot ser criados.
A vida útil de um snapshot é determinada pelo backlog da origem assinatura. A vida útil é igual a 7 dias menos a idade da mensagem não confirmada mais antiga na assinatura. Por exemplo, considere um snapshot dos uma assinatura com um backlog em que a mensagem não confirmada mais antiga tem um dia. idosas. O snapshot expira em seis dias. Esse cronograma é necessário para snapshots para oferecer uma garantia sólida de entrega pelo menos uma vez.
O ciclo de vida máximo possível de um snapshot é de sete dias. Não é possível criar um snapshot que expire em menos de 1 hora após o antes de sua criação.
O recurso de busca permite buscar um snapshot ou carimbo de data/hora específico de uma assinatura. Esse recurso permite controlar como o Pub/Sub entregar mensagens de um momento específico ou de um snapshot específico.
Para procurar um horário no passado e repetir mensagens confirmadas anteriormente, é necessário configurar a retenção de mensagens no tópico ou configurar a assinatura para reter mensagens confirmadas.
Consistência posterior das operações de busca
As operações de busca são estritamente consistentes em relação à entrega de mensagens. garantia. Isso significa que toda mensagem que não for confirmada na condição de busca tem a garantia de ser entregue depois que a operação de busca for concluída. No entanto, as mensagens entregues não se tornam instantaneamente consistentes com a operação de busca. Portanto, uma mensagem que foi publicada antes do carimbo de data/hora de busca ou que está confirmada em um snapshot pode ser entregue após a operação de busca. De certa forma, a entrega de mensagens opera como uma sistema de consistência posterior em relação à operação de busca; pode demorar até um minuto para que a operação tenha efeito total.
Casos de uso de operações de busca
- Atualize o código do assinante com segurança. Uma preocupação com a implantação de um novo código de assinante é que o novo executável possa confirmar mensagens erroneamente, levando à perda delas. A incorporação de instantâneos no seu processo de implantação permite se recuperar de bugs no novo código do assinante.
- Recupere-se de problemas inesperados do assinante. Se os problemas do assinante não estiverem associados a um evento de implantação específico, pode ser que você não tenha um instantâneo relevante. Nesse caso, se você tiver ativado a retenção de mensagens confirmadas para uma assinatura, buscar um horário no passado permitirá que você se recupere do erro.
- Economize tempo e custo de processamento. Realize uma confirmação em massa em um grande backlog de mensagens que não são mais relevantes.
- Teste o código do assinante em dados conhecidos. Ao testar o código do assinante quanto a desempenho e consistência, vale a pena usar os mesmos dados em todas as execuções. Os snapshots proporcionam dados consistentes com semântica forte. Além disso, os snapshots podem ser aplicados a qualquer assinatura de um determinado tópico, incluindo uma recém-criada.
Configurar a retenção de mensagens
Você pode configurar a retenção de mensagens em um tópico e configurar qualquer um dos para reter mensagens confirmadas. É possível configurar o tópico retenção de mensagens se você quiser que as mensagens sejam retidas para repetição por um período por mais tempo que a retenção de mensagens configurada na assinatura. Nessa situação, o projeto do tópico e o projeto da assinatura são cobrados pelo armazenamento de mensagens de acordo com as respectivas configurações de retenção de mensagens.
Se a retenção de mensagens de tópico não estiver configurada, uma mensagem não confirmada será excluída da assinatura quando a idade exceder a propriedade message_retention_duration da assinatura. Por outro lado, se a retenção de mensagens de tópico
estiver configurada, a mensagem não confirmada será excluída da
assinatura somente quando a idade exceder o máximo do tópico e das
message_retention_durations da assinatura.
Configurar a retenção de mensagens de tópico
Por padrão, um tópico do Pub/Sub descarta mensagens assim que são
confirmadas por todas as assinaturas anexadas a ele.
Configurar um tópico com retenção de mensagens oferece mais flexibilidade, permitindo
qualquer assinatura anexada ao tópico para voltar no tempo e reproduzir
mensagens confirmadas anteriormente até
message_retention_duration
A retenção de mensagens de tópicos também permite que uma assinatura reproduza mensagens publicadas antes de você criar uma assinatura.
Um tópico pode reter mensagens publicadas por até 31 dias (configurável pela
propriedade message_retention_duration do tópico), mesmo depois
de elas serem confirmadas por todas as assinaturas anexadas. Nos casos em que o message_retention_duration do tópico é maior que o message_retention_duration da assinatura, o Pub/Sub descarta uma mensagem somente quando a idade excede o message_retention_duration do tópico.
Se a retenção de mensagens de tópicos estiver ativada, os custos de armazenamento das mensagens retidas pelo tópico são cobradas no projeto do tópico.
Console
Para criar um tópico com a retenção de mensagens ativada, siga estas etapas:
No console do Google Cloud, acesse a página Tópicos do Pub/Sub.
Clique em Criar tópico.
No campo Código do tópico, insira um código para o tópico.
Ative a opção Definir a duração da retenção de mensagens.
Não altere as outras opções.
Use o menu suspenso Duração da retenção de mensagens para selecionar o número de dias, horas e minutos para reter mensagens.
Clique em Criar tópico para salvar o tópico.
Para atualizar as configurações de retenção de mensagens de um tópico:
Selecione o tópico na página Tópicos do Pub/Sub.
Clique em Editar também na parte superior da página de detalhes do tópico.
Ajuste o tempo de retenção ou ative/desative a retenção de mensagens marcando ou desmarcando a opção Ativar retenção de mensagens.
Clique em Atualizar para salvar as alterações no tópico.
gcloud
Para criar um tópico com uma duração de retenção de mensagem de sete dias, use o seguinte comando gcloud pubsub topics create:
gcloud pubsub topics create TOPIC_ID --message-retention-duration=7d
É possível atualizar essa configuração usando gcloud pubsub topics update.
Isso também permite ativar a retenção de mensagens em um tópico existente:
gcloud pubsub topics update TOPIC_ID --message-retention-duration=1d
Também é possível desativar a retenção de mensagens para um tópico com o comando update:
gcloud pubsub topics update TOPIC_ID --clear-message-retention-duration
Configurar a retenção de mensagens de assinatura
O Pub/Sub começa a reter mensagens em nome de uma assinatura quando
a assinatura é criada. Por padrão, o Pub/Sub descarta uma
de uma assinatura assim que a mensagem é confirmada.
As mensagens não confirmadas são retidas por um padrão de sete dias (configurável por
o message_retention_duration da assinatura
).
Configurar uma assinatura para reter mensagens confirmadas (usando o
retain_acked_messages
) permite reproduzir mensagens confirmadas anteriormente
retido pela assinatura. É possível configurar a retenção das mensagens por um
máximo de sete dias em uma assinatura. Essa configuração se aplica
mensagens confirmadas e não confirmadas. No entanto, as mensagens podem ser retidas em uma
assinatura por mais de sete dias se a duração da retenção de mensagens configurada
no tópico for maior que sete dias.
Se uma assinatura estiver configurada para reter mensagens confirmadas, os custos de armazenamento das mensagens confirmadas retidas pela assinatura são cobradas do projeto da assinatura.
Console
Para criar uma assinatura com a retenção de mensagens visualizadas ativadas, siga estas etapas:
No console do Google Cloud, acesse a página Assinaturas do Pub/Sub.
Clique em Criar assinatura.
No campo ID da assinatura, insira um ID para a assinatura.
Use o menu suspenso Duração da retenção de mensagens para selecionar o número de dias, horas e minutos para reter mensagens.
Ative Reter mensagens confirmadas. Não altere as outras opções.
Clique em Criar assinatura para salvá-la.
Para atualizar as configurações de retenção de mensagens de uma assinatura:
Selecione sua assinatura na página de Assinaturas do Pub/Sub.
Clique em Editar também na parte superior da página de detalhes da assinatura.
Ajuste a duração da retenção de mensagens ou ative ou desative a retenção de mensagens mensagens marcando ou desmarcando o campo Reter confirmados .
Clique em Atualizar para salvar as mudanças na assinatura.
gcloud
Para criar uma assinatura com a retenção de mensagens visualizadas ativadas, use o
seguinte
comando gcloud pubsub subscriptions create:
gcloud pubsub subscriptions create SUBSCRIPTION_ID --retain-acked-messages --message-retention-duration=5d
É possível atualizar essa configuração usando
gcloud pubsub subscriptions update.
Isso também permite que você ative a retenção de mensagens confirmadas para um
assinatura:
gcloud pubsub subscriptions update SUBSCRIPTION_ID --message-retention-duration=1d
Também é possível desativar a retenção de mensagens visualizadas para uma assinatura com o comando update:
gcloud pubsub subscriptions update SUBSCRIPTION_ID --no-retain-acked-messages
Criar um snapshot
É possível criar um snapshot usando o console, as APIs do Google ou a CLI do Google Cloud.
Console
Para criar um snapshot, siga estas etapas:
No console do Google Cloud, acesse a página Snapshots.
Clique em Criar snapshot.
Em Selecionar uma assinatura do Pub/Sub, escolha uma opção.
Em ID do snapshot, insira um nome para ele.
Para mais informações sobre como nomear recursos do Pub/Sub, consulte Diretrizes para nomear um tópico, uma assinatura, um esquema ou um snapshot.
Clique em Criar para criar o snapshot.
Também é possível criar um snapshot na página Assinaturas. Se você criar um snapshot imediatamente após criar uma assinatura, é possível um erro devido ao atraso na propagação da assinatura recém-criada.
gcloud
Para criar um snapshot, use o
comando
gcloud pubsub snapshots create
abaixo:
gcloud pubsub snapshots create \ --project=PROJECT_ID \ --subscription=SUBSCRIPTION_ID \ SNAPSHOT_ID
Substitua:
PROJECT_ID. Especifica o ID do projeto.SUBSCRIPTION_ID: Especifica o ID da assinatura.SNAPSHOT_ID: Especifica o ID do snapshot.
Buscar um carimbo de data/hora
A busca por um horário marca todas as mensagens recebidas pelo Pub/Sub antes e depois do horário de confirmação.
É possível executar os seguintes tipos de operações de busca com base em carimbos de data/hora:
Para limpar todas as mensagens, procure um horário no futuro.
Para reproduzir e reprocessar mensagens confirmadas anteriormente, procure um no passado.
O horário de publicação da mensagem é gerado pelo Pub/Sub
servidores (consulte
publishTime
na referência da API). Essa abordagem é imprecisa pelos seguintes motivos:
Os relógios dos servidores do Pub/Sub podem ter diferenças.
O Pub/Sub precisa trabalhar com o horário de chegada da solicitação de publicação em vez de quando um evento ocorreu no sistema de origem.
É possível buscar um carimbo de data/hora usando o console, as APIs do Google ou a CLI do Google Cloud. Antes de buscar um carimbo de data/hora em uma assinatura, verifique se a retenção de mensagens está ativada na assinatura.
Console
Para isso, siga estas etapas:
No console do Google Cloud, acesse a página Assinatura.
Clique em uma assinatura que tenha a retenção de mensagens ativada.
Na página de detalhes da assinatura, clique em Repetir mensagens.
Em Procurar, clique em Para um ponto anterior no tempo.
Selecione uma data e hora apropriadas e clique em Procurar.
gcloud
Para buscar um carimbo de data/hora, use a função
seguindo
gcloud pubsub subscriptions seek
comando:
gcloud pubsub subscriptions seek SUBSCRIPTION_ID \ --time=TIME \
Substitua:
- TIME: o tempo em que você quer realizar a operação de busca.
- SUBSCRIPTION_ID: o ID da assinatura.
Para mais informações sobre os formatos de tempo aceitos, consulte Data e hora no gcloud.
Procurar um snapshot
É possível reproduzir mensagens não confirmadas usando um snapshot para buscar qualquer das inscrições do tópico.
Diferentemente da busca por um horário, não é preciso executar nenhuma configuração de assinatura especial para procurar um snapshot. Você só precisa criar o snapshot com antecedência. Por exemplo, é possível criar um snapshot ao implantar um novo código de assinante, caso precise se recuperar de confirmações inesperadas ou errôneas.
Se o backlog na assinatura for muito antigo e o snapshot resultante expira em menos de 1 hora, a operação de busca falha.
É possível buscar um Instant Snapshot usando o console, as APIs do Google ou a CLI do Google Cloud.
Console
Para buscar um snapshot, siga estas etapas:
No console do Google Cloud, acesse a página Assinatura.
Clique em uma assinatura.
Na página de detalhes da assinatura, clique em Repetir mensagens.
Em Busca, clique em Para um snapshot.
Selecione um snapshot adequado e clique em Procurar.
gcloud
Para buscar um snapshot, use o
comando
gcloud pubsub subscriptions seek
a seguir:
gcloud pubsub subscriptions seek SUBSCRIPTION_ID \ --snapshot=SNAPSHOT_ID
Substitua:
- SNAPSHOT_ID: o ID de um snapshot. O tópico do snapshot precisa ser o mesmo da assinatura.
- SUBSCRIPTION_ID: o ID da assinatura.
Procurar com filtros
Você pode reproduzir mensagens novamente a partir de assinaturas com filtros. Se você buscar um carimbo de data/hora usando uma assinatura com um filtro, o serviço do Pub/Sub só reenviará as mensagens que corresponderem ao filtro.
Um snapshot de uma assinatura com um filtro contém as seguintes mensagens:
- Todas as mensagens que são mais recentes que o snapshot, incluindo aquelas que não correspondem ao filtro.
- Mensagens não confirmadas que são mais antigas do que o snapshot.
Se você buscar um snapshot usando uma assinatura com um filtro, o serviço do Pub/Sub só reenviará as mensagens no snapshot que corresponderem ao filtro da assinatura que faz a solicitação de busca.
Para mais informações sobre filtros, consulte Como filtrar mensagens.
Pesquisar tópicos de mensagens mortas
Se você buscar mensagens em uma assinatura com um tópico de mensagem inativa,
o Pub/Sub definirá as tentativas de entrega como 0. As mensagens recebidas dessas assinaturas têm um campo que registra o número de tentativas de entrega.
Para mais informações sobre tópicos de mensagens inativas, consulte Como encaminhar para tópicos de mensagens inativas.
Busca com políticas de repetição
Se você buscar mensagens em uma assinatura com uma política de nova tentativa, o Pub/Sub redefinirá o atraso entre os seguintes itens:
- O prazo de confirmação expira ou o assinante envia uma confirmação negativa.
- O Pub/Sub reenvia a mensagem.
Para mais informações sobre políticas de nova tentativa, consulte Como usar políticas de nova tentativa.
Procurar com entrega exatamente uma vez
Se você buscar mensagens em uma assinatura com exatamente uma entrega, O Pub/Sub reenvia as mensagens confirmadas anteriormente que são qualificadas para exibição. Quaisquer confirmações, para uma entrega feita antes da busca vai falhar. As operações de busca são consistência posterior.
Para mais informações sobre políticas de repetição, consulte Entrega exatamente uma vez.