Relire un message dans Pub/Sub en recherchant un instantané ou un code temporel

Pub/Sub ne peut pas récupérer les messages une fois que vous les avez confirmés. Cependant, il peut parfois s'avérer nécessaire de relire les messages confirmés, par exemple si vous avez effectué un accusé de réception erroné. Vous pouvez ensuite utiliser la fonctionnalité Rechercher pour marquer les messages précédemment confirmés comme non confirmés et forcer Pub/Sub à les redistribuer. Vous pouvez également utiliser la fonctionnalité de recherche pour supprimer les messages non confirmés en remplaçant leur état par "Confirmé".

Recherchez un instantané ou un horodatage pour relire les messages d'un abonnement. Ce guide fournit des exemples illustrant comment relire des messages Pub/Sub précédemment confirmés à l'aide de la fonctionnalité de recherche.


Pour obtenir des instructions détaillées sur cette tâche directement dans la console Google Cloud, cliquez sur Visite guidée :

Visite guidée


Avant de commencer

  1. Connectez-vous à votre compte Google Cloud. Si vous débutez sur Google Cloud, créez un compte pour évaluer les performances de nos produits en conditions réelles. Les nouveaux clients bénéficient également de 300 $ de crédits gratuits pour exécuter, tester et déployer des charges de travail.
  2. Configurez un projet dans la console Google Cloud.

    Configurer un projet

    Cliquez pour effectuer les opérations suivantes :

    • Créer ou sélectionner un projet
    • Activez l'API Pub/Sub pour ce projet.

    Vous pouvez consulter et gérer ces ressources à tout moment dans la console Google Cloud.

  3. Installez Google Cloud CLI.
  4. Pour initialiser gcloudCLI, exécutez la commande suivante :

    gcloud init
  5. Configurez un projet dans la console Google Cloud.

    Configurer un projet

    Cliquez pour effectuer les opérations suivantes :

    • Créer ou sélectionner un projet
    • Activez l'API Pub/Sub pour ce projet.

    Vous pouvez consulter et gérer ces ressources à tout moment dans la console Google Cloud.

  6. Installez Google Cloud CLI.
  7. Pour initialiser gcloudCLI, exécutez la commande suivante :

    gcloud init

Utiliser l'interface de ligne de commande gcloud

Le moyen le plus simple d'utiliser gcloud est de recourir à Cloud Shell. Vous pouvez également utiliser l'outil de ligne de commande fourni avec la Google Cloud CLI. Les conditions préalables de configuration sont automatiquement remplies pour la gcloud CLI si vous créez une toute nouvelle instance de machine Compute Engine avec des niveaux d'accès incluant toutes les APIs Cloud et l'image Debian par défaut. La méthode la plus facile pour créer cette instance est d'utiliser l'interface utilisateur de Compute Engine. Dans la suite de ce document, nous partons du principe que vous vous servez de l'un de ces outils de ligne de commande.

Pour en savoir plus sur l'utilisation de gcloud, consultez le Guide de démarrage rapide de gcloud. Lisez également la section consacrée à gcloud pubsub de la documentation de référence sur gcloud pour découvrir la liste complète des commandes gcloud utilisables dans Pub/Sub.

Créer et rechercher des instantanés

Créez un sujet et un abonnement. Pour profiter d'une meilleure interactivité, choisissez un délai de confirmation court :

gcloud pubsub topics create seek-demo-topic
gcloud pubsub subscriptions create seek-demo-sub --topic=seek-demo-topic --ack-deadline=10

Jusqu'à présent, aucun message de l'abonnement n'a été confirmé. Enregistrez cet état en créant un instantané :

gcloud pubsub snapshots create my-snapshot --subscription=seek-demo-sub
gcloud pubsub snapshots list

Maintenant, publiez et extrayez un message. Ensuite, confirmez sa réception :

gcloud pubsub topics publish seek-demo-topic --message 'hello, world'
gcloud pubsub subscriptions pull --auto-ack seek-demo-sub

Notez que les extractions suivantes ne génèrent aucun nouveau message, mais certains doubles transitoires sont possibles :

gcloud pubsub subscriptions pull --auto-ack seek-demo-sub

Vous pouvez récupérer le message en recherchant l'abonnement associé à l'instantané. Sachez que le message peut ne pas être distribué instantanément : Pub/Sub ne garantit pas la latence de diffusion des messages. Pub/Sub certifie toutefois que les messages conservés dans l'instantané seront distribués au moins une fois :

gcloud pubsub subscriptions seek seek-demo-sub --snapshot=my-snapshot
gcloud pubsub subscriptions pull seek-demo-sub --auto-ack

Notez que vous pouvez rechercher d'autres abonnements au même instantané, à condition que le sujet de l'abonnement soit identique à celui de l'instantané:

gcloud pubsub subscriptions create seek-demo-sub2 --topic=seek-demo-topic --ack-deadline=10
gcloud pubsub subscriptions seek seek-demo-sub2 --snapshot=my-snapshot

L'extraction depuis seek-demo-sub2 affiche désormais les messages publiés avant la création de seek-demo-sub2 :

gcloud pubsub subscriptions pull seek-demo-sub2 --auto-ack

Lorsque vous en avez terminé avec l'instantané, effectuez un nettoyage :

gcloud pubsub snapshots delete my-snapshot

Rechercher un horodatage

Pour rouvrir les messages confirmés, vous pouvez également rechercher un horodatage. Pour ce faire, vous devez d'abord configurer l'abonnement de manière à conserver les messages confirmés à l'aide de retain-acked-messages. Si retain-acked-messages est défini, Pub/Sub conserve les messages confirmés pendant sept jours.

Cette opération n'est à effectuer que si vous souhaitez rechercher un horodatage, et non un instantané.

gcloud pubsub subscriptions update seek-demo-sub --retain-acked-messages

Maintenant, publiez et extrayez un message. Ensuite, confirmez sa réception :

gcloud pubsub topics publish seek-demo-topic --message 'hello, world'
gcloud pubsub subscriptions pull --auto-ack seek-demo-sub

La prochaine extraction ne doit renvoyer aucun message :

gcloud pubsub subscriptions pull seek-demo-sub

Remontez à présent dans le temps pour rechercher l'abonnement et récupérer le message. Sachez que les indicateurs arithmétiques de la date diffèrent entre les versions GNU et BSD (macOS) de la commande 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)

Une extraction ultérieure doit à nouveau afficher le message :

gcloud pubsub subscriptions pull --auto-ack seek-demo-sub

Vous pouvez également vous servir de la fonctionnalité de recherche pour ignorer la distribution de tous les messages publiés avant un moment précis, tel que la date et l'heure actuelles. Pour ce faire, recherchez l'abonnement à la date et l'heure actuelles afin de marquer tous les messages passés comme confirmés :

gcloud pubsub topics publish seek-demo-topic --message 'hello, world'
gcloud pubsub subscriptions seek seek-demo-sub --time=$(date -u +$TS_FORMAT)

Après un certain temps de propagation (60 secondes environ), le message ne sera plus distribué. Vous pouvez le vérifier en exécutant à plusieurs reprises la commande pull sans accuser réception du message :

gcloud pubsub subscriptions pull seek-demo-sub

Utiliser Cloud Console

Vous pouvez créer des instantanés ou rechercher des instantanés existants sur la page d'informations sur l'abonnement de la console Cloud. Pour connaître les règles d'attribution de noms aux instantanés, consultez la section Noms de ressources.

Créer un instantané

  1. Dans la console Google Cloud, accédez à la page Abonnements Pub/Sub.

    Accéder à la page Abonnements

  2. Sélectionnez un abonnement dans la liste.

  3. Cliquez sur Create snapshot (Créer un instantané).

  4. Saisissez un ID pour l'instantané, puis cliquez sur Créer pour l'enregistrer.

Vous pouvez afficher les instantanés sur la page Instantanés dans la console Google Cloud. Vous pouvez également gérer des instantanés depuis la page des détails d'un sujet particulier :

Rouvrir un abonnement

La boîte de dialogue Rouvrir les messages vous permet de rechercher un moment antérieur dans le temps ou un instantané enregistré. Pour ouvrir la boîte de dialogue, procédez comme suit :

  1. Dans la console Google Cloud, accédez à la page Abonnements Pub/Sub.

    Accéder à la page Abonnements

  2. Sélectionnez un abonnement dans la liste.

  3. Cliquez sur Relire les messages.

  4. Sous Rechercher, sélectionnez Un moment antérieur ou Un instantané, puis sélectionnez le moment ou l'instantané à rechercher.

  5. Cliquez sur Rechercher pour revoir les messages.

Comment ça s'est passé ?

Notez que des ressources et des liens supplémentaires sont disponibles sur la page d'assistance Pub/Sub.

Étapes suivantes

Consultez la page Rouvrir et supprimer des messages.