Итак, я играю с потоками данных Kinesis, и меня интересует, как получить данные из потока эффективно (наилучшая практика для этого)?
У меня есть некоторые соображения по поводу это:
1. Использование AWS Lamba.
Звучит хорошо, но что, если у моего потребителя какой-то экземпляр, я должен перенаправить лямбду в мой экземпляр для получения некоторых данных? Кажется неэффективным ...
2. Использование опроса.
Как я понимаю, использование опроса не является хорошей идеей, оно вызывает перегрузки.
3. Asyn c клиент от aws -sdk для Ruby.
Я пытался проверить это , но кажется LocalStack не имеет http2. Получение ошибки: SSL_connect returned=1 errno=0 state=error: wrong version number (Seahorse::Client::NetworkingError). Вы пробовали это с реальной AWS учетной записью?
Итак, для резюме, я хочу спросить сообщество о более эффективном способе получения данных из потоков данных Kinesis.
Заранее спасибо.