amazon-kinesis

0зной

1ответ

Каким образом записи, помещенные в Kinesis, должны быть эффективно упакованы, если они меньше, чем минимальная единица полезной нагрузки в 25 КБ?

Обновление: Чтобы подробнее узнать о проблеме, put_records оплачивается в зависимости от количества представленных записей (разделов) и размера записей. Любая запись, которая меньше 25 КБ, заряжается

0зной

1ответ

Является ли DynamoDB правильным вариантом для этого варианта использования?

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

0зной

1ответ

Могу ли я отменить геокодирование данных с помощью Amazon Kinesis Analytics?

При использовании Amazon Kinesis для обработки большого объема входящих точек lat/long данных, каков наилучший способ для изменения геокода в масштабе? Использование KINESIS Analytics можно использова

0зной

1ответ

Kinesis: Запрос подписи мы рассчитали не совпадает с подписью вы предоставили

Я пытаюсь описать поток Kinesis, и я получаю следующее сообщение об ошибке: {u'message': u"The request signature we calculated does not match the signature you provided. Check your AWS Secret Access K

1зной

1ответ

Является ли Kinesis правильным инструментом для моих нужд? (& другие сортированные вопросы)

Мне нужно обработать на пике 100 с записей в секунду. Эти записи являются простыми органами JSON, и их следует собирать, а затем обрабатывать/преобразовывать в базу данных. Несколько вопросов ... 1) Я

0зной

1ответ

Spark Streaming with Kinesis - Как заставить контрольно-пропускной пункт?

У меня есть потоковое приложение, которое считывает данные от Aws Kinesis. По умолчанию при создании ресиверов потока вы можете выбрать, с какого интервала сделать контрольную точку, что делается на D

4зной

2ответ

Разделение Kinesis firehose S3 записи по времени события

Firehose-> S3 использует текущую дату в качестве префикса для создания ключей в S3. Таким образом, это разделяет данные к моменту записи записи. Мой поток firehose содержит события, которые имеют опре

1зной

1ответ

Как я могу выяснить, какой конкретный запрос Lambda вызвал событие Kinesis?

У меня есть лямбда AWS, которая подключена к (возбужденному) потоком AWS Kinesis. Когда я запускаю события в Кинезисе, меня зовут лямбда. Вот пример кода, который толкает события в Kinesis (эта часть

0зной

1ответ

отправить запрос sql в аналитику kinesis по sdk или rest api?

Любой API позволяет отправлять SQL-запрос с моего сервера на кинезис-аналитику? Я не могу найти соответствующий API в официальном документе SDK.

0зной

2ответ

Входной поток Kinesis в Logstash

В настоящее время я оцениваю Logstash для наших потребностей в потреблении данных. Одним из вариантов использования является считывание данных из потока AWS Kinesis. Я попытался установить плагин logs