amazon-kinesis

9зной

1ответ

Данные потока из двоичного журнала MySQL в Kinesis

У нас есть таблица интенсивной записи (на AWS RDS MySQL) из унаследованной системы, и мы хотели бы передать каждое событие записи (вставить или обновить) из этой таблицы в кинезис. Идея состоит в том,

0зной

1ответ

Как разобрать данные из 2 x потоков Kinesis в 1 x Spark Streaming App?

Я пытаюсь сделать запрос, select a.user_id , b.domain from realTimeTable_1 as a join realTimeTable_2 as b on a.device_id = b.device_id с использованием двух кинезисов Потоков. Однако выход из Stream2

0зной

1ответ

Amazon Kinesis аналитика для данных архивных

Фон Я обнаружил, что Amazon Kinesis Analytics, можно использовать для потоковой передачи данных, а также данных, присутствующих в S3 ведро. Однако, есть некоторые упоминания в документации, которые ст

0зной

1ответ

Сколько потребителей запускает Spark для потока Kinesis?

У меня есть Spark Cluster (1.6.1) с 1 ведущим и 4 подчиненными, работающими на Мезосе. Искра, я запускаю данные процесса из Kinesis Stream. Код работает отлично, за исключением того, что я вижу, что S

4зной

1ответ

Управление Lambda + Kinesis Costs

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

0зной

1ответ

Агент Kinesis не преобразует записи в JSON

Я использую агент Amazon Kinesis для того, чтобы заводить журналы доступа к журналу nginx с целью нажатия на журнал доступа к Kinesis, что в конечном итоге будет использоваться в Kinesis Analytics. Аг