Ты можешь сделать это! Что-то вроде...
Хитрость в том, чтобы использовать параметр «ExplicitHashKey».
Это позволяет вам установить хэш-ключ, используемый для записи, и, следовательно, позволяет выбрать, в каком сегменте будут храниться ваши данные.
Затем вы можете позвонить
aws kinesis describe-stream --stream-name name-of-your-stream
чтобы получить информацию о каждом осколке, включая диапазон хэшей, покрываемый каждым осколком.
Затем вам нужно только отправить свои данные на каждый сегмент (с помощью PutRecord или PutRecords), и все готово.
К сожалению, «трансляции» нет, но вы можете легко написать Lambda для отправки одних и тех же данных на каждый шард, используя параметр ExplicitHashKey.
Другое решение — использовать отдельные потоки и записывать в каждый из них.
person
Mike
schedule
22.05.2018