amazon-kinesis

0зной

1ответ

Как изменить порядок асинхронно отправленных событий Kinesis внутри KCL

Я работаю над приложением, которое считывает и обрабатывает события из потока AWS Kinesis Stream с помощью клиентской библиотеки Kinesis (KCL). Я не хочу, чтобы сторона, производящая события, страдала

0зной

1ответ

Kinesis - кластер потребителей

У меня есть поток кинезий, который используется для очереди в задаче, скажем, отправки электронных писем. У меня есть группа потребителей, которые должны читать очередь, а затем отправлять электронные

5зной

1ответ

Как мы можем использовать AWS Kinesis в веб-браузере?

Как мы можем использовать AWS Kinesis в веб-браузере? Меня интересует AWS Kinesis Stream и интересно, могу ли я использовать его для отправки журналов активности пользователей непосредственно из их бр

1зной

4ответ

Пример потоковой передачи Kinesis, не работающий в режиме кластера на EMR (EMR 4.3, Spark 1.6)

Я безуспешно пытаюсь запустить версию примера подсчета слов Kinesis Streaming в EMR 4.3 в режиме кластера. В частности, никакие сообщения не читаются из Kinesis, хотя я могу получить доступ к метаданн

7зной

1ответ

Как работают контрольные точки Kinesis искровой потоковой приемник

Мы используем Spark Streaming, подключенный к потоку AWS Kinesis, чтобы агрегировать (в минуту) показатели, которые мы получаем, и записывать агрегаты в infuxdb, чтобы сделать их доступными для панель

1зной

1ответ

Использование стандартного имени профиля в поставщике учетных данных AWS?

Как указать именованный профиль (например, «myprofile») в качестве поставщика учетных данных AWS? У меня есть клиент AWS Kinesis, которые в настоящее время использует учетные данные, хранящиеся в прил

1зной

1ответ

Kinesis to Redshift COPY Команда с использованием JSONPaths Ошибка файла

Я пытаюсь отправить записи вызовов API на S3, а затем только конкретные поля для красного смещения. Например, моя программа посылает следующий JSON в S3 успешно: { "user": "user_name", "type": "GET",

1зной

1ответ

Spark Streaming 1.6.0 EMR с использованием Python: ClassNotFoundException: org.apache.spark.streaming.kinesis.KinesisUtilsPythonHelper

Я запускаю готовый EMR-кластер, используя Spark 1.6.0 и Zeppelin 0.5.6 on AWS. Моя цель - инициализировать простой контекст Spark Streaming и указать на внутренний поток Kinesis, как на доказательство