Vuelve a reproducir y borra definitivamente mensajes con saltos

Después de confirmar los mensajes en Pub/Sub, el cliente suscriptor ya no puede acceder a ellos. Además, los clientes suscriptores deben procesar todos los mensajes de una suscripción, incluso si solo se necesita un subconjunto.

La función Buscar amplía las capacidades del suscriptor, ya que te permite modificar el estado de confirmación de los mensajes de forma masiva. Por ejemplo, puedes reproducir mensajes ya confirmados o borrar definitivamente mensajes de forma masiva. Además, puedes copiar el estado de acuse de recibo de una suscripción en otra mediante la búsqueda en combinación con una instantánea.

Para ver una demostración rápida de cómo funcionan estas funciones, consulta Cómo buscar una instantánea o una marca de tiempo para volver a reproducir un mensaje en Pub/Sub.

Descripción general de instantáneas y búsquedas

Una instantánea de Pub/Sub es una vista duradera, coherente y confiable de un momento determinado del estado de confirmación (acuse de recibo) del mensaje de una suscripción. Una instantánea registra el estado de confirmación de todos los mensajes de una suscripción en el momento de su creación. Una instantánea retiene los mensajes no confirmados de la suscripción de origen en el momento de su creación, así como los mensajes publicados en el tema después de que se crea la instantánea.

El ciclo de vida de una instantánea se determina según las tareas pendientes existentes de la suscripción de origen. El ciclo de vida es igual a 7 días menos la antigüedad del mensaje no confirmado más antiguo de la suscripción. Por ejemplo, imagina una instantánea de una suscripción con una tarea pendiente en la que el mensaje no confirmado más antiguo tiene 1 día de antigüedad. La instantánea vence después de 6 días. Esta línea de tiempo es necesaria para que las instantáneas ofrezcan garantías de entrega sólidas al menos una vez.

La vida útil máxima posible de una instantánea es de siete días. No puedes crear una instantánea que venza en menos de 1 hora después de su creación.

La función de búsqueda te permite buscar una instantánea o una marca de tiempo específicas para una suscripción. Esta función te permite controlar cómo Pub/Sub puede entregar mensajes desde un momento específico o desde una instantánea específica.

Para buscar una hora anterior y volver a reproducir mensajes ya confirmados, primero debes configurar la retención de mensajes en el tema o configurar la suscripción para que retenga los mensajes confirmados.

Coherencia eventual de las operaciones de búsqueda

Las operaciones de búsqueda son estrictamente coherentes con respecto a la garantía de entrega de mensajes. Esto significa que cualquier mensaje que se convertirá en no confirmado en función de la condición de búsqueda, se entregará, al menos una vez, después de que la operación de búsqueda tenga éxito. Sin embargo, los mensajes enviados no son coherentes de inmediato con la operación de búsqueda. Por lo tanto, un mensaje que se publicó antes de la marca de tiempo de búsqueda o que se confirmó en una instantánea podría entregarse después de la operación de búsqueda. En cierto sentido, la entrega de mensajes funciona como un sistema de coherencia eventual con respecto a la operación de búsqueda: la operación puede tardar hasta un minuto para surtir efecto.

Casos de uso para operaciones de búsqueda

• Actualiza el código de suscriptor de forma segura. Un problema con la implementación de un nuevo código de suscriptor es que el ejecutable nuevo puede confirmar mensajes de forma errónea, lo que puede provocar la pérdida de mensajes. La incorporación de instantáneas en el proceso de implementación te permite recuperarte antes errores en el nuevo código de suscriptor.
• Recupérate ante problemas inesperados de suscriptores. En los casos en los que los problemas del suscriptor no estén asociados con un evento de implementación específico, es posible que no tengas una instantánea relevante. En ese caso, si habilitaste la retención de mensajes confirmados para una suscripción, la búsqueda de un horario anterior te brinda una forma de recuperarte ante el error.
• Reduce los costos y el tiempo de procesamiento. Realiza una confirmación masiva de una gran cantidad de mensajes pendientes que ya no son relevantes.
• Prueba el código del suscriptor en datos conocidos. Cuando se prueba el rendimiento y la coherencia del código del suscriptor, es útil usar los mismos datos en cada ejecución. Las instantáneas son compatibles con datos coherentes con una semántica sólida. Además, las instantáneas se pueden aplicar a cualquier suscripción a un tema determinado, incluso una nueva.

Configura la retención de mensajes

Puedes configurar la retención de mensajes en un tema y configurar cualquiera de sus suscripciones para retener mensajes confirmados. Te recomendamos que configures la retención de mensajes del tema si deseas que los mensajes se conserven durante más tiempo que la retención de mensajes configurada en la suscripción. En esta situación, se cobra al proyecto del tema y al proyecto de suscripción por el almacenamiento de mensajes según su configuración de retención de mensajes correspondiente.

Si no se configura la retención de mensajes de temas, un mensaje no confirmado se borrará de la suscripción cuando su antigüedad supere la propiedad message_retention_duration de la suscripción. Por otro lado, si se configura la retención de mensajes de tema, el mensaje no confirmado se borra de la suscripción solo cuando su antigüedad supera el máximo de los message_retention_duration del tema y de la suscripción.

Configura la retención de mensajes por temas

De forma predeterminada, un tema de Pub/Sub descarta los mensajes en cuanto los reconocen todas las suscripciones adjuntas al tema. Configurar un tema con retención de mensajes te brinda más flexibilidad, lo que permite que cualquier suscripción adjunta al tema pueda realizar búsquedas en el tiempo y volver a reproducir mensajes ya confirmados hasta el message_retention_duration del tema. La retención de mensajes por tema también permite que una suscripción vuelva a reproducir mensajes que se publican antes de que crees una suscripción.

Un tema puede retener los mensajes publicados durante un máximo de 31 días (configurable por la propiedad message_retention_duration del tema), incluso después de que todas las suscripciones adjuntas los hayan confirmado. En los casos en que el message_retention_duration del tema es mayor que el message_retention_duration de la suscripción, Pub/Sub descarta un mensaje solo cuando su antigüedad supera el message_retention_duration del tema.

Si la retención de mensajes de temas está habilitada, los costos de almacenamiento de los mensajes retenidos por tema se facturan en el proyecto del tema.

gcloud pubsub topics create TOPIC_ID --message-retention-duration=7d

gcloud pubsub topics update TOPIC_ID --message-retention-duration=1d

gcloud pubsub topics update TOPIC_ID --clear-message-retention-duration

Configura la retención de mensajes de suscripción

Pub/Sub comienza a retener mensajes en nombre de una suscripción cuando se crea. De forma predeterminada, Pub/Sub descarta un mensaje de una suscripción en cuanto se confirma. Los mensajes no confirmados se retienen durante un período predeterminado de 7 días (configurable por la propiedad message_retention_duration de la suscripción).

Configurar una suscripción para que retenga los mensajes confirmados (con la propiedad retain_acked_messages) te permite repetir los mensajes que ya se confirmaron que retiene la suscripción. Puedes configurar los mensajes para que se retengan por un máximo de 31 días en una suscripción. Esta configuración se aplica a los mensajes confirmados y no confirmados.

Si se configura una suscripción para que retenga los mensajes confirmados, los costos de almacenamiento de los mensajes confirmados que retenga la suscripción se facturarán al proyecto de la suscripción.

gcloud pubsub subscriptions create SUBSCRIPTION_ID
    --retain-acked-messages
    --message-retention-duration=5d

gcloud pubsub subscriptions update SUBSCRIPTION_ID --message-retention-duration=1d

gcloud pubsub subscriptions update SUBSCRIPTION_ID --no-retain-acked-messages

Crear una instantánea

Puedes crear una instantánea con la consola, las APIs de Google o la CLI de Google Cloud.

gcloud pubsub snapshots create \
    --project=PROJECT_ID \
    --subscription=SUBSCRIPTION_ID \
    SNAPSHOT_ID

Busca una marca de tiempo

Cuando se busca un horario, se marcan todos los mensajes recibidos por Pub/Sub antes de ese horario como confirmados y todos los mensajes recibidos después como no confirmados.

Puedes realizar los siguientes tipos de operaciones de salto según las marcas de tiempo:

• Para borrar definitivamente todos los mensajes, puedes buscar un horario en el futuro.

• Para volver a reproducir y procesar mensajes ya confirmados, busca un horario anterior.

Los servidores de Pub/Sub generan el horario de publicación del mensaje (consulta publishTime en la referencia de la API). Este enfoque es impreciso debido a los siguientes motivos:

• Un posible sesgo del reloj entre los servidores Pub/Sub

• El hecho de que Pub/Sub tenga que trabajar con el horario de llegada de la solicitud de publicación en lugar de hacerlo cuando ocurre un evento en el sistema de origen

Puedes buscar una marca de tiempo con la consola, las APIs de Google o la CLI de Google Cloud CLI. Antes de buscar una marca de tiempo en una suscripción, asegúrate de que la retención de mensajes esté habilitada en la suscripción.

gcloud pubsub subscriptions seek SUBSCRIPTION_ID \
    --time=TIME \

Busca una instantánea

Puedes volver a reproducir mensajes no confirmados si usas una instantánea para buscar cualquiera de las suscripciones del tema.

A diferencia de la búsqueda de un horario, no necesitas realizar ninguna configuración de suscripción especial para buscar una instantánea. Solo debes crear la instantánea con anticipación. Por ejemplo, puedes crear una instantánea cuando implementes un código nuevo de suscriptor, en caso de que necesites solucionar confirmaciones inesperadas o erróneas.

Si el retraso en la suscripción es demasiado antiguo y la instantánea resultante vencería en menos de 1 hora, la operación de búsqueda falla.

Puedes buscar una instantánea con la consola, las APIs de Google o Google Cloud CLI.

gcloud pubsub subscriptions seek SUBSCRIPTION_ID \
    --snapshot=SNAPSHOT_ID

Busca con filtros

Puedes volver a reproducir mensajes de suscripciones con filtros. Si buscas una marca de tiempo con una suscripción con un filtro, el servicio de Pub/Sub solo vuelve a entregar los mensajes que coincidan con el filtro.

Una instantánea de una suscripción con un filtro contiene los siguientes mensajes:

• Todos los mensajes más nuevos que la instantánea, incluidos los mensajes que no coinciden con el filtro.
• Mensajes no confirmados que son más antiguos que la instantánea.

Si buscas una instantánea mediante una suscripción con un filtro, el servicio de Pub/Sub solo vuelve a entregar los mensajes en la instantánea que coinciden con el filtro de la suscripción que realiza la solicitud de búsqueda.

Para obtener más información sobre los filtros, consulta Filtra mensajes.

Busca temas de mensajes no entregados

Si buscas mensajes en una suscripción con un tema de mensajes no entregados, Pub/Sub establece los intentos de entrega como 0. Los mensajes que recibes de estas suscripciones tienen un campo que cuenta la cantidad de intentos de entrega.

Para obtener más información sobre los temas de mensajes no entregados, consulta Reenvío a temas de mensajes no entregados.

Busca con políticas de reintento

Si buscas mensajes en una suscripción con una política de reintento, Pub/Sub restablece el retraso entre lo siguiente:

1. El plazo de confirmación de recepción vence o el suscriptor envía una confirmación de recepción negativa.
2. Pub/Sub reenvía el mensaje.

Para obtener más información sobre las políticas de reintento, consulta Usa políticas de reintento.

Salto con entrega “exactamente una vez”

Si buscas mensajes en una suscripción con una entrega única, Pub/Sub vuelve a enviar los mensajes confirmados anteriormente que sean apto para la entrega. Los acuse de recibo de una entrega realizada antes de la operación de búsqueda fallarán. Las operaciones de búsqueda son coherentes de forma eventual.

Para obtener más información sobre las políticas de reintento, consulta Entrega única exacta.