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.
Die Verwendung des Amazon-Kinesis-Adapters ist die empfohlene Methode zum Verwenden von Streams aus Amazon DynamoDB. Die DynamoDB-Streams-API ist absichtlich ähnlich gestaltet wie die Kinesis Data Streams, einem Service für die Verarbeitung riesiger Mengen von Streaming-Daten in Echtzeit. In beiden Services bestehen die Daten-Streams aus Shards. Dieses sind Container für Stream-Datensätze. Beide Dienste APIs enthaltenListStreams, DescribeStreamGetShards, und GetShardIterator Operationen. (Diese DynamoDB-Streams-Aktionen ähneln ihren Gegenstücken in Kinesis Data Streams, sind jedoch nicht vollkommen identisch.)
Sie können Anwendungen für Kinesis Data Streams mit der Kinesis Client Library (KCL) schreiben. Die KCL vereinfacht die Codierung durch Bereitstellen nützlicher Abstraktionen oberhalb der Low-Level-Kinesis-Data-Streams-API. Weitere Informationen zur KCL finden Sie im Entwickeln von Konsumenten mit der Kinesis-Client-Library im Entwicklerhandbuch zu Amazon Kinesis Data Streams.
Die aktuelle KCL-Version 1.x mit AWS SDK for Java v1.x wird während ihres gesamten Lebenszyklus weiterhin vollständig unterstützt, um Stabilität und Leistung zu gewährleisten. Wenn Sie das bestehende SDK verwenden, funktionieren Ihre vorhandenen Anwendungen, die AWS SDK for Java v1.x verwenden, während der Übergangszeit gemäß den Wartungsrichtlinien für Tools weiterhin wie vorgesehen.AWS SDKs
Als DynamoDB-Streams-Benutzer können Sie das Entwurfsmuster in der KCL zum Verarbeiten von DynamoDB-Streams-Shards und Stream-Datensätzen verwenden. Verwenden Sie dazu den DynamoDB-Streams-Kinesis-Adapter. Der Kinesis-Adapter implementiert die Kinesis-Data-Streams-Schnittstelle so, dass die KCL zum Verwenden und Verarbeiten von Datensätzen aus DynamoDB Streams eingesetzt werden kann. Anweisungen zur Einrichtung und Installation des DynamoDB Streams Kinesis Adapters finden Sie im Repository. GitHub
Das folgende Diagramm zeigt, wie diese Bibliotheken miteinander interagieren.
Wenn Sie den DynamoDB-Streams-Kinesis-Adapter eingerichtet haben, können Sie die Entwicklung mit der KCL-Schnittstelle starten, wobei die API-Aufrufe nahtlos an den DynamoDB-Streams-Endpunkt gerichtet werden.
Beim Start der Anwendung wird die KCL aufgerufen, einen Worker zu instanziieren. Sie müssen dem Worker Konfigurationsinformationen für die Anwendung, wie z. B. den Stream-Deskriptor und die AWS Anmeldeinformationen, sowie den Namen einer von Ihnen angegebenen Datensatzprozessorklasse zur Verfügung stellen. Da der Code im Datensatzprozessor ausgeführt wird, erledigt der Worker die folgenden Aufgaben:
-
Stellt eine Verbindung mit dem Stream her
-
Listet die Shards innerhalb des Streams auf
-
Koordiniert Shard-Zuordnungen mit anderen Auftragnehmern (wenn vorhanden)
-
Instanziiert einen Datensatzverarbeiter für jeden Shard, der verwaltet wird
-
Ruft Datensätze aus dem Stream per Pull ab
-
Überträgt per Push Datensätze an den entsprechenden Datensatzverarbeiter
-
Verwendet Checkpoints für verarbeitete Datensätze
-
Gleicht Shard-Auftragnehmer-Zuordnungen aus, wenn die Auftragnehmer-Instance Änderungen zählt
-
Gleicht Shard-Worker-Zuordnungen aus, wenn Shards aufgeteilt werden
Anmerkung
Eine Beschreibung der hier aufgeführten KCL-Konzepte finden Sie unter Entwickeln von Konsumenten mithilfe der Kinesis-Clientbibliothek im Amazon-Kinesis-Data-Streams-Entwicklerhandbuch.
Weitere Informationen zur Verwendung von Streams mit AWS Lambda finden Sie unter DynamoDB Streams und -Trigger AWS Lambda
