API-шлюз Kinesis Proxy - Shard Iterator

Я успешно настроил API-шлюз Kinesis Proxy. Но я не могу понять, как равномерно распределить записи по нескольким осколкам.

Вот пример использования:

  • у нас есть большой объем веб-хуков для обработки (большой объем = миллионы каждый день)

  • эти веб-хуки попадают в API Gateway (с вызовом POST), API Gateway передает информацию /json-body в Kinesis, а лямбда-поток обрабатывает поток Kinesis.

  • Веб-хуки взяты от третьей стороны, и мы не можем контролировать содержимое тела или заголовков.

  • Я использую только putRecords функциональность.

Я знаю, что мне нужно добавить какой-нибудь генератор случайных чисел или итератор Shard в шаблон отображения в API Gateway, но я не уверен, как это сделать.

{
"StreamName": "webhook_queue",
"Data": "$util.base64Encode($input.json('$'))",
"PartitionKey": "<HOW DO I MAKE THIS ITERATE THROUGH SHARDS!>"
}
Источник

0 ответов

Другие вопросы по тегам