Потоки Amazon DynamoDB вводят новую функцию API для более быстрого и эффективного обнаружения сегментов потоков
Потоки Amazon DynamoDB теперь поддерживают новый параметр ShardFilter в API DescribeStream для упрощения и оптимизации приема потоковых данных. Параметр ShardFilter можно использовать для быстрого обнаружения дочерних сегментов после закрытия родительского, что значительно повышает эффективность и скорость обработки данных из Потоков DynamoDB.
Потоки DynamoDB – это бессерверная функция потоковой передачи данных, которая позволяет легко отслеживать и обрабатывать изменения на уровне элементов в таблицах DynamoDB, а также реагировать на них в режиме, близком к реальному времени. Потоки DynamoDB подходят для различных примеров использования сбора данных об изменениях, в том числе для создания приложений, управляемых событиями, репликации данных, аудита, а также внедрения функций аналитики данных и машинного обучения. С помощью этого дополнительного параметра ShardFilter приложения, принимающие данные из Потоков DynamoDB, могут эффективно переходить от чтения закрытого сегмента к дочернему сегменту без необходимости повторно вызывать API DescribeStream с целью извлечения и просмотра карты сегментов для всех закрытых и открытых сегментов. Это усовершенствование API помогает обеспечить большую плавность и меньшую задержку при переключении между сегментами, делая ваши приложения для обработки потоковых данных более быстрыми и экономичными.
Новый параметр ShardFilter доступен во всех регионах AWS. Начать работу с этой функцией можно с помощью API AWS, клиентской библиотеки Kinesis (KCL) 3.0 или коннектора Apache Flink для Потоков DynamoDB. Клиенты, использующие AWS Lambda для получения данных из Потоков DynamoDB, получат доступ к этому усовершенствованию API автоматически.
Подробнее см. в разделе Работа с Потоками DynamoDB из Руководства для разработчиков по DynamoDB, а также в справочнике по API DescribeStream.