Entwickeln benutzerdefinierter Verbraucher mit dediziertem Durchsatz (Erweitertes Rundsenden) - Amazon-Kinesis-Data-Streams

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Entwickeln benutzerdefinierter Verbraucher mit dediziertem Durchsatz (Erweitertes Rundsenden)

In Amazon Kinesis Data Streams können Sie Verbraucher erstellen, die ein Feature namens erweiterte Rundsendungen verwenden. Mit dieser Funktion können Verbraucher Datensätze aus einem Stream empfangen, mit einem Durchsatz von bis zu 2 MB Daten pro Sekunde pro Shard. Dieser Durchsatz ist dediziert, d. h. dass Verbraucher, die ein erweitertes Rundsenden verwenden, nicht mit anderen Verbrauchern konkurrieren müssen, die Daten aus dem Stream empfangen. Kinesis Data Streams überträgt Datensätze aus dem Stream zu den Verbrauchern die ein erweitertes Rundsenden verwenden. Aus diesem Grund müssen diese Verbraucher keine Daten abfragen.

Wichtig

Sie können bis zu zwanzig Nutzer pro Stream registrieren, um das erweiterte Rundsenden zu verwenden.

Das folgende Diagramm zeigt die Architektur für das erweiterte Rundsenden. Wenn Sie die Version 2.0 oder höher der Amazon Kinesis Client Library (KCL) verwenden, um einen Verbraucher zu erstellen, richtet die KCL den Verbraucher so ein, dass er erweitertes Rundsenden verwendet, um Daten von allen Shards des Streams zu empfangen. Wenn Sie die API verwenden, um einen Verbraucher zu erstellen, der ein erweitertes Rundsenden verwendet, können Sie einzelne Shards abonnieren.

Workflow-Diagramm der Architektur für erweitertes Rundsenden mit zwei Shards und zwei Verbrauchern. Jeder der beiden Verbraucher verwendet erweitertes Rundsenden, um Daten von beiden Shards des Streams zu empfangen.

Das Diagramm zeigt Folgendes:

  • Einen Stream mit zwei Shards.

  • Zwei Verbraucher, die erweitertes Rundsenden verwenden, um Daten vom Stream zu empfangen: Consumer X und Consumer Y. Beide Verbraucher haben alle Shards und alle Datensätze im Stream abonniert. Wenn Sie die Version 2.0 oder höher der KCL verwenden, um einen Verbraucher zu erstellen, abonniert die KCL automatisch alle Shards des Streams. Wenn Sie dagegen die API verwenden, um einen Verbraucher zu erstellen, können Sie einzelne Shards abonnieren.

  • Pfeile stellen die Pipes für das erweiterte Rundsenden dar, die die Verbraucher verwenden, um Daten aus dem Stream zu erhalten. Eine Pipe für erweitertes Rundsenden liefert bis zu 2 MB/s Daten pro Shard, unabhängig von anderen Pipes oder der Gesamtzahl der Verbraucher.