Amazon DynamoDB Streams führt ein neues API-Feature für eine schnellere und effizientere Stream-Shard-Erkennung 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 erkennen, nachdem ein übergeordnetes Shard geschlossen wurde, wodurch die Effizienz und Reaktionsfähigkeit bei der Verarbeitung von Daten aus DynamoDB-Streams erheblich verbessert werden.
Amazon DynamoDB Streams ist ein Serverless-Daten-Streaming-Feature, das die Verfolgung, Verarbeitung und Beantwortung von Änderungen auf Elementebene in DynamoDB-Tabellen nahezu in Echtzeit ermöglicht. DynamoDB Streams ermöglicht vielfältige Anwendungsfälle zur Erfassung von Änderungsdaten, darunter die Entwicklung ereignisgesteuerter Anwendungen, Datenreplikation, Prüfung und Implementierung von Datenanalyse- und maschinellen Lernfunktionen. Anwendungen, die Daten aus DynamoDB-Streams verwenden, können mithilfe dieses optionalen ShardFilter-Parameters effizient vom Lesen eines geschlossenen Shards zum untergeordneten Shard übergehen. Dadurch werden wiederholte Aufrufe der DescribeStream-API zum Abrufen und Durchlaufen der Shard-Map für alle geschlossenen und offenen Shards vermieden. Diese API-Erweiterung sorgt für reibungslosere Übergänge und eine geringere Latenz beim Wechsel zwischen Shards, wodurch Ihre Anwendungen zur Stream-Verarbeitung reaktionsschneller und kostengünstiger werden.
Der neue ShardFilter-Parameter ist in allen AWS-Regionen verfügbar. Sie können mit dem Feature beginnen, indem Sie die AWS-API, Kinesis Client Library (KCL) 3.0 oder den Apache-Flink-Connector für DynamoDB-Streams verwenden. Kunden, die AWS Lambda zur Nutzung von DynamoDB-Streams verwenden, profitieren automatisch von dieser verbesserten API-Erfahrung.
Weitere Informationen finden Sie unter Arbeiten mit DynamoDB-Streams im DynamoDB-Entwicklerhandbuch und in der API-Referenz für DescribeStream.