Потоки Amazon DynamoDB теперь поддерживают потоковую обработку на основе временных меток
Потоки Amazon DynamoDB теперь поддерживают потоковую обработку на основе временных меток, что позволяет начать чтение записей потоков с определенного момента времени. Раньше можно было начать только с самой старой сохраненной записи (до 24 часов) или с новых записей, записанных после начала использования потока. Теперь можно ввести метку времени и начать обработку первой записи, записанной в это время или позже, используя тип итератора сегментов AT_TIMESTAMP.
Потоковую обработку на основе временных меток можно использовать в клиентской библиотеке Amazon Kinesis (KCL) через адаптер DynamoDB Streams Kinesis. Она позволяет избежать повторной обработки всех сохраненных потоков или пропуска записей при возобновлении использования потока, поддерживая такие распространенные примеры использования, как восстановление после перерыва, воспроизведение данных для отладки и аудит путем считывания данных с определенного момента в прошлом, устранение отставания, возобновление с недавней временной метки рядом с последними записями и синхронизация после восстановления, начиная с отметки времени экспорта после экспорта восстановления на определенный момент времени (point-in-time recovery, PITR).
Обработка потоковых данных на основе меток времени доступна во всех коммерческих регионах AWS, регионах AWS GovCloud (США) и регионах Китая. За эту функцию не взимается дополнительная плата, кроме стандартной платы за запросы API GetRecords. Для начала работы см. документацию по меткам времени Потоков Amazon DynamoDB в руководстве для разработчиков DynamoDB.