Amazon DynamoDB Streams führt eine neue API-Funktion für eine schnellere und effizientere Ermittlung von Stream-Shards ein.

"Amazon DynamoDB Streams unterstützt jetzt einen neuen ShardFilter-Parameter in der DescribeStream API, um den Verbrauch von Streaming-Daten zu vereinfachen und zu optimieren. Sie können den ShardFilter-Parameter verwenden, um untergeordnete Shards schnell zu entdecken, nachdem ein übergeordneter Shard geschlossen wurde. Dies verbessert die Effizienz und Reaktionsfähigkeit bei der Verarbeitung von Daten aus DynamoDB Streams erheblich. DynamoDB Streams ist eine serverlose Datenstreaming-Funktion, die es einfach macht, Elementänderungen in DynamoDB-Tabellen nahezu in Echtzeit zu verfolgen, zu verarbeiten und darauf zu reagieren. DynamoDB Streams ermöglicht vielfältige Anwendungsfälle für die Erfassung von Änderungsdaten, einschließlich der Erstellung ereignisgesteuerter Anwendungen, der Datenreplikation, der Auditierung sowie der Implementierung von Datenanalyse- und Machine-Learning-Funktionen. Anwendungen, die Daten aus DynamoDB Streams verbrauchen, können mit diesem optionalen ShardFilter-Parameter effizient von der Lektüre eines geschlossenen Shards zu seinem untergeordneten Shard wechseln und vermeiden so wiederholte Aufrufe der DescribeStream API, um die Shard-Map für alle geschlossenen und offenen Shards abzurufen und zu durchlaufen. Diese API-Erweiterung sorgt für reibungslosere Übergänge und geringere Latenzzeiten beim Wechsel zwischen Shards, wodurch Ihre Stream-Verarbeitungsanwendungen reaktionsschneller und kostengünstiger werden. Der neue ShardFilter-Parameter ist in allen AWS-Regionen verfügbar. Sie können mit der Funktion beginnen, indem Sie die AWS API, die Kinesis Client Library (KCL) 3.0 oder den Apache Flink Connector für DynamoDB Streams verwenden. Kunden, die AWS Lambda zur Verarbeitung von DynamoDB Streams verwenden, profitieren automatisch von dieser erweiterten API-Erfahrung. Weitere Informationen finden Sie unter "Working with DynamoDB Streams" im DynamoDB Developer Guide und in der API-Referenz für DescribeStream."