Oracle Cloud Infrastructure - Dokumentation

Nachrichten konsumieren

Verwenden Sie einen angegebenen Cursor, um Nachrichten aus einem Stream im Streaming-Service zu konsumieren.

Um Nachrichten aus einem Stream zu konsumieren, müssen Sie folgende Schritte ausführen:

  • Cursor erstellen
  • Nachrichten mit dem Cursor abrufen oder lesen.
  • Den zurückgegebenen Cursor verwenden, um mit dem Lesen von Nachrichten fortzufahren

Sie können Nachrichten mit einem einzelnen Consumer aus einem oder mehreren Streams lesen oder Nachrichten mit Consumer-Gruppen aus einem Stream lesen.

Im Folgenden finden Sie Aufgaben, die Sie im Zusammenhang mit dem Konsumieren von Nachrichten ausführen können.

Tipp

Sie können auch Oracle Cloud Infrastructure Connector Hub verwenden, um Daten aus einem Stream zu konsumieren und Nachrichten an Object Storage oder ein anderes unterstütztes Connector Hub-Ziel zu übergeben.

Mit der Konsole können Sie die neuesten Nachrichten in einem Stream anzeigen. Um jedoch Nachrichten aus dem Stream zu konsumieren, verwenden Sie die CLI, API oder ein SDK, um Cursor zu erstellen und zu verwenden.

Informationen zum Konsumieren von Nachrichten mit OCI-SDKs finden Sie in der Entwicklerdokumentation für Streaming. Siehe auch Mit Kafka und Streaming entwickeln.

Erforderliche IAM-Policy

Um Oracle Cloud Infrastructure verwenden zu können, muss ein Administrator Mitglied einer Gruppe sein, der von einem Mandantenadministrator Sicherheitszugriff in einer Policy erteilt wurde. Dieser Zugriff ist unabhängig davon erforderlich, ob Sie die Konsole oder die REST-API mit einem SDK, einer CLI oder einem anderen Tool verwenden. Wenn Sie eine Nachricht erhalten, dass Sie keine Berechtigung haben oder nicht autorisiert sind, fragen Sie den Mandantenadministrator, welcher Zugriffstyp Ihnen erteilt wurde und in welchem Compartment Ihr Zugriff funktioniert.

Für Administratoren: Mit der unter Verwalten von Streaming-Ressourcen durch Streaming-Administratoren zulassen beschriebenen Policy kann die angegebene Gruppe alle Aktionen mit Streaming und zugehörigen Streaming-Serviceressourcen ausführen.

Sie können eine Policy erstellen, die einem Mandanten stream-pull-Zugriff zum Konsumieren von Daten aus einem Stream in einem anderen Mandanten erteilt. Weitere Informationen zu Streaming-Policys finden Sie unter Auf Streamingressourcen mandantenübergreifend zugreifen und Details zum Streaming-Service.

Wenn Sie mit Policys noch nicht vertraut sind, finden Sie weitere Informationen unter Überblick über IAM-Policys.