Я работаю в Kinesis Data Generator (KDG) для нагрузочного тестирования моего Kinesis Stream. Мне...
Я пытаюсь получить данные из потока данных Kinesis: function getRecord(shard_iterator) { var...
Рассмотрим архитектуру ниже (источник здесь ): Зачем нам нужны Потоки данных Kinesis ?Если данные...
Это относительно простой вопрос относительно начальных требований.В настоящее время происходит...
Фактическая ситуация Я хочу использовать Apache Flink с Kinesis Analytics.Как будто у меня нет...
Сейчас я работаю на клиентской стороне Amazon Kinesis Video Streams, используя video.js и...
Возможно обрабатывать данные геопространственных данных с помощью SQL в Kinesis Data Analytics, как...
Я пытаюсь использовать Apache Flink с кинесисом AWS.В документе говорится, что я должен создать...
Я пытаюсь использовать аналитику кинезиса поверх журнала доступа Apache.Я использую...
Я пытаюсь получить все записи из потока данных Kinesis для отображения в виде непрерывной подачи на...
Когда я вставляю объект данных в поток AWS, используя операцию put, он работает нормально....
Я надеялся настроить поток Amazon Kinesis для непосредственного использования данных Twitter без...
Существует множество примеров того, как данные сохраняются AWS Firehose в корзину S3 и параллельно...
Учетная запись A - это учетная запись приложения, в которой я создал поток Kinesis, и я хочу...
Как указано в документации AWS Максимальный размер полезных данных записи до кодирования base64...
У меня есть Lambda, настроенная в качестве потребителя потока данных Kinesis, с размером пакета 10...
Я хочу просто отключить лямбда-повторы, когда он запускается кинезисом.Если лямбда выйдет из строя...
Вопрос Я прочитал это и это и это статьи.Но они дают противоречивые ответы на вопрос: как настроить...
В AWSKinesisRecorder ( здесь ), как мы можем проверить, были ли наши записи отправлены на сервер /...
Я пишу производителю для отправки сообщений в поток Kinesis с помощью библиотек потокового облака...
Есть ли способ создать пользователя Kinesis с ограничениями буфера?Как и здесь : #Flush when buffer...
Я использую java AWS SDK для потребления записей кинезиса по одной за раз. В частности, я пытаюсь...
Ниже приведен код, который должен подключаться к другой учетной записи AWS Kinesis и помещать...
Я запустил kinesis local stream с помощью следующей команды kinesalite --port 4567 Но я не могу...
Мои настройки: scala:2.11.8 spark:2.3.0.cloudera4 Я уже добавил это в мой .pom файл:...