amazon-kinesis

0зной

1ответ

Что означает использовать «Amazon ES для рекомендаций по содержанию»?

Глядя на маркетинговую литературу для аналитики amazon kinesis, я просматриваю их поток аналитики журнала в реальном времени, и у них есть 4-й шаг, на котором данные передаются в Amazon ES для предлож

0зной

2ответ

Интеграция с кинсисом Spark Streaming: ошибка при инициализации LeaseCoordinator у рабочего

У меня возникли некоторые проблемы при запуске простой струйной искрообразования с применением кинезиса в scala. В некоторых руководствах я руководствовался основными руководствами: Snowplow и WordCou

0зной

1ответ

Местный кинезит: кинесал + boto3

Я хочу настроить клиент boto3 kinesis таким образом, чтобы он использовал кинесалит. Чтобы я мог работать полностью локально. любые идеи?

0зной

1ответ

Скомпилировать приложение примера кинезирования искрового потока с помощью инструмента SBT

Я пытаюсь скомпилировать и создать банку для приложения Scala kinesis stream scala, предоставленного самой игрой в данной ссылке. Kinesis word count sample Ниже представлен мой sbt-файл. Он имеет все

0зной

1ответ

Как периодически обновлять объекты на рабочих Spark?

У меня есть требование в моем приложении Spark, где мне нужно периодически обновлять переменную, которая будет использоваться рабочим кодом. Для более конкретного понимания мне нужно поместить мои дан

0зной

1ответ

Spark Streaming - Ошибка при чтении из Kinesis

Я новичок в Apache Spark Streaming. Попытка построить Spark для чтения ценности от Kinesis Stream. Это мой питон скрипт import settings from pyspark import SparkContext from pyspark.streaming import

0зной

2ответ

DynamoDB to Kinesis Stream

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