Nachrichten in Pub/Sub durch Springen zu einem Snapshot oder Zeitstempel wiedergeben

Pub/Sub kann die Nachrichten nicht mehr abrufen, nachdem Sie sie bestätigt haben. Manchmal kann es jedoch erforderlich sein, die bestätigten Nachrichten wiederzugeben, z. B. wenn Sie eine fehlerhafte Bestätigung durchgeführt haben. Anschließend können Sie mit der Funktion Suchen zuvor bestätigte Nachrichten als nicht bestätigt markieren und Pub/Sub dazu zwingen, diese Nachrichten noch einmal zuzustellen. Sie können die unbestätigten Nachrichten auch löschen, indem Sie ihren Status in „Bestätigt“ ändern.

Suchen Sie einen Snapshot oder einen Zeitstempel, um die Nachrichten in einem Abo noch einmal abzuspielen. In dieser Anleitung finden Sie Beispiele für die Wiedergabe zuvor bestätigter Pub/Sub-Nachrichten mithilfe der Funktion „Seek“.


Klicken Sie auf Anleitung, um eine detaillierte Anleitung für diese Aufgabe direkt in der Google Cloud Console aufzurufen.

Anleitung


Hinweis

  1. Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.
  2. Set up a Google Cloud console project.

    Set up a 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.

  3. Install the Google Cloud CLI.
  4. To initialize the gcloud CLI, run the following command:

    gcloud init
  5. Set up a Google Cloud console project.

    Set up a 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.

  6. Install the Google Cloud CLI.
  7. To initialize the gcloud CLI, run the following command:

    gcloud init

gcloud-Befehlszeilenoberfläche verwenden

gcloud lässt sich am einfachsten in der Cloud Shell verwenden. Sie können auch das im Google Cloud CLI enthaltene Befehlszeilentool verwenden. Die Einrichtungsvoraussetzungen für die gcloud CLI werden automatisch erfüllt, wenn Sie eine neue Compute Engine-Maschineninstanz mit Zugriffsbereichen erstellen, die alle Cloud APIs und das Standard-Debian-Image enthalten. Am einfachsten erstellen Sie sie über die Compute Engine-Benutzeroberfläche. Für den Rest dieses Dokuments gehen wir davon aus, dass Sie eines dieser Befehlszeilentools verwenden.

Weitere Informationen zur Verwendung von gcloud finden Sie im Schnellstart zu gcloud. Eine vollständige Liste der Pub/Sub-gcloud-Befehle finden Sie auch im Abschnitt zu gcloud pubsub in der Referenz zu gcloud.

Snapshots erstellen und bis Snapshot suchen

Erstellen Sie ein Thema und ein Abo. Die Interaktion ist besser, wenn Sie eine kurze Bestätigungsfrist angeben:

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

Bisher wurden keine Nachrichten im Abo bestätigt. Erfassen Sie diesen Zustand, indem Sie einen Snapshot erstellen:

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

Nun wird eine Nachricht veröffentlicht, abgerufen und bestätigt:

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

Nachfolgende Abrufe mit Pull liefern keine neuen Nachrichten. Kurzzeitige Duplikate sind möglich:

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

Sie können die Nachricht wiederherstellen, indem Sie im Abo bis zum Snapshot suchen. Die Nachricht wird unter Umständen nicht sofort zugestellt: Pub/Sub garantiert keine Nachrichtenzustellungslatenz. Es wird jedoch garantiert, dass die im Snapshot enthaltenen Nachrichten mindestens einmal zugestellt werden:

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

Sie können auch in anderen Abos bis zum selben Snapshot suchen, wenn das Thema des Abos mit dem des Snapshots identisch ist:

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

Beim Abrufen von seek-demo-sub2 werden jetzt Nachrichten ausgegeben, die vor der Erstellung von seek-demo-sub2 veröffentlicht wurden:

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

Bereinigen Sie zum Schluss die Snapshots:

gcloud pubsub snapshots delete my-snapshot

Bis Zeitstempel suchen

Sie haben auch die Möglichkeit, alle bestätigten Nachrichten zu suchen, die bis zu einem bestimmten Zeitstempel aufbewahrt wurden, und dann wiederzugeben. Um einen Zeitstempel zu suchen, müssen Sie zuerst das Abo so konfigurieren, dass bestätigte Nachrichten mithilfe von retain-acked-messages aufbewahrt werden. Wenn retain-acked-messages festgelegt ist, speichert Pub/Sub bestätigte Nachrichten sieben Tage lang.

Dieser Schritt muss nur ausgeführt werden, wenn Sie bis zu einem Zeitstempel suchen. Für die Suchfunktion bis Snapshot ist er nicht relevant.

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

Nun wird eine Nachricht veröffentlicht, abgerufen und bestätigt:

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

Beim nächsten Abruf mit Pull sollten keine Nachrichten zurückgegeben werden:

gcloud pubsub subscriptions pull seek-demo-sub

Suchen Sie jetzt im Abo zeitlich zurück, um die Nachricht wiederherzustellen. Das arithmetische Datums-Flag in den GNU- und BSD-Versionen (MacOS) des Date-Befehls weicht ab:

export TS_FORMAT=%Y-%m-%dT%H:%M:%SZ
gcloud pubsub subscriptions seek seek-demo-sub --time=$(date -u -d '-10 min' +$TS_FORMAT)

Weitere Informationen zu unterstützten Zeitformaten Siehe gcloud topic datetimes.

Der nachfolgende Abruf mit Pull sollte die Nachricht nun wieder zurückgeben:

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

Sie haben auch die Möglichkeit, mit Seek die Zustellung aller Nachrichten zu überspringen, die vor einem bestimmten Zeitpunkt, beispielsweise dem aktuellen Zeitpunkt, veröffentlicht wurden. Suchen Sie dazu im Abo bis zur aktuellen Uhrzeit. Alle Nachrichten in der Vergangenheit werden damit als bestätigt markiert:

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

Nach einer gewissen Verzögerung (~60 Sekunden) wird die Nachricht nicht mehr zugestellt. Sie können das überprüfen, indem Sie den Pull-Befehl wiederholt ausführen, ohne die Nachricht zu bestätigen:

gcloud pubsub subscriptions pull seek-demo-sub

Cloud Console verwenden

Sie können im Abo Snapshots erstellen oder zu vorhandenen Snapshots suchen der Cloud Console. Regeln zur Benennung von Snapshots finden Sie unter Ressourcennamen.

Snapshot erstellen

  1. Rufen Sie in der Google Cloud Console die Seite Pub/Sub-Abos auf.

    Zur Seite "Abos"

  2. Wählen Sie ein Abo aus der Liste aus.

  3. Klicken Sie auf Snapshot erstellen.

  4. Geben Sie eine ID für den Snapshot ein und klicken Sie zum Speichern auf Erstellen.

Snapshots können in der Google Cloud Console auf der Seite „Snapshots“ aufgerufen werden. Snapshots können auch auf der Detailseite eines Themas verwaltet werden.

Abo wiederholen

Im Dialogfeld Nachrichten wiedergeben können Sie zu einem vorherigen Zeitpunkt oder zu einem gespeicherten Snapshot suchen. So öffnen Sie das Dialogfeld:

  1. Rufen Sie in der Google Cloud Console die Seite Pub/Sub-Abos auf.

    Zur Seite "Abos"

  2. Wählen Sie ein Abo aus der Liste aus.

  3. Klicken Sie auf Nachrichten wiedergeben.

  4. Wählen Sie unter Suchen entweder Zu einem vorherigen Zeitpunkt oder Zu einem Snapshot aus und wählen Sie dann den Zeitpunkt oder den Snapshot für die Suche aus.

  5. Klicken Sie auf Suchen, um Nachrichten noch einmal wiederzugeben.

Wie ist es gelaufen?

Weitere Ressourcen und Links finden Sie auf der Pub/Sub-Supportseite.

Nächste Schritte

Siehe Nachrichten wiedergeben und verwerfen.