Описание тега apache-camel-aws-kinesis
1
ответ
Как использовать контрольную точку Apache Camel AWS-KINESIS для проверки контрольной точки в потоке Kinesis?
Я использую конечную точку AWS-KINESIS в Camel для чтения из потока содержимого AWS Kinesis. Я могу читать сообщения очень хорошо, но как мне проверить сообщение в потоке? В стандартной клиентской библиотеке AWS Kinesis Java есть концепция "Рабочие …
04 май '17 в 11:35
0
ответов
AWS Kinesis Stream использует node.js без ввода
Я использую этот пример. В этом потребителе мне нужно передать входные данные, откуда я могу получить такие как initializeInput, processRecordsInput для соответствующих методов: Вот код, initialize: function(initializeInput, completeCallback) { cons…
27 июн '18 в 10:06
1
ответ
Активизировать лямбда-сигнал AWS для определенного события Kinesis
Я новичок в области AWS лямбда. Я создаю функцию, которая будет использовать события Kinesis. Но я хочу запустить свою лямбда-функцию, когда конкретное событие получает толчок к кинезису (не для всех событий толчок к кинезису). Есть ли способ, котор…
23 авг '18 в 09:28
1
ответ
AWS Kinesis, обязательно ли использовать S3 для кинезиса?
Не могли бы вы дать некоторую ясность в использовании s3 в Kinesis? Спасибо субхам
25 фев '19 в 10:05
0
ответов
Мне нужно прочитать данные из потока aws-kinesis. Может кто-нибудь, пожалуйста, объясните, как это сделать, используя модуль узла aws-sdk/aws-kcl?
Чтение данных из потока kinesis aws с использованием kcl recordProcessor . Может кто-нибудь объяснить реализацию recordProcessor?
10 авг '18 в 15:00
1
ответ
Ввод агента Kinesis - файл журнала, созданный для каждого дня
Новый файл журнала создается для каждого дня с добавлением даты в имени. Например, файл журнала "data_log-2017-05-14" создан для 14 мая. Мне нужно настроить Kinesis Agent для чтения данных из сгенерированных журналов. Но поскольку каждый день создае…
19 май '17 в 11:33
0
ответов
Как преобразовать строковый файл из потока Kinesis в файл JSON
Может ли кто-нибудь помочь мне в этом. Я пытаюсь преобразовать мой файл строки в файл JSON. Строковый файл я получаю из потока Kinesis.
12 июл '18 в 08:01
0
ответов
Поток видео на S3
Для случая использования я хочу хранить данные потокового видео в течение 15 дней, в то время как максимальный срок хранения составляет 7 дней согласно документам. Я попытался создать поток с более чем 15-дневным сроком и успешно создал его без каки…
23 май '19 в 09:06
1
ответ
Как декодировать выходные данные AWS Kinesis Video Stream GetMedia API в mp3/wav?
Я загружал данные в (Kinesis Video Stream) KVS через сервис AWS Connect, теперь с помощью API GetMedia могу извлечь полезную нагрузку, но как я могу преобразовать этот вывод в mp3/wav? Я хочу передать этот вывод службе AWS Transcribe, чтобы получить…
18 мар '19 в 19:09
0
ответов
Использование AWS Kinesis Data Stream с несколькими шардами с использованием KCL в узле js
У нас есть один производитель и один поток данных Kinesis. Для достижения более высокой пропускной способности нам нужно несколько осколков. Поместить данные на несколько сегментов в поток данных Kinesis - это хорошо. Как я могу использовать данные …
16 мар '19 в 18:54
0
ответов
Интеграция кинезов Aws с потоковой передачей Spark ничего не дает, как показано ниже
Высоко ценим помощь Использование Spark 2.4.5,scala 2.11.8 с пакетом ниже --packages org.apache.spark:spark-streaming-kinesis-asl_2.12:2.4.5--packages org.apache.spark:spark-streaming-kinesis-asl_2.11:2.4.5 import sys from pyspark import SparkContex…
25 авг '20 в 09:21
0
ответов
AWS-Kinesis-Agent может записывать данные в Kinesis-Firehose из докера, который работает внутри EC2, но не может из самого EC2.
Поскольку я новичок в сервисе kinesis, я понятия не имею, что не так. Я настроил AWS-Kinesis-Agent, который может записывать данные в Kinesis-Firehose из докера, работающего внутри EC2, но тот же агент с той же конфигурацией не может записывать данн…
09 дек '19 в 09:37
0
ответов
Лямбда-функция срабатывает более одного раза
Я пытаюсь создать на AWS следующую архитектуру. Архитектура AWS У меня к ядру Iot подключено 3 устройства: -Термометр -Кондиционер -Лямбда-функция Термометр должен каждые 5 секунд отправлять данные о температуре в ядро, затем данные телеметрии отпра…
28 дек '19 в 14:26
1
ответ
Попытка понять сигнальные каналы WebRTC
Помогите разобраться, как работает сигнализация в WebRTC. В частности, если у меня есть определенный канал, скажем, с использованием Amazon Kinesis или аналогичного продукта, как одноранговый узел узнает, какому узлу позвонить? Нужен ли мне выделенн…
10 апр '20 в 00:35
1
ответ
Видеопоток AWS kinesis в raspberrypi. Невозможно создать видеопоток Kinesis Video
Я пытаюсь транслировать видео с малинового пирога, используя видеопоток aws kinesis. Мы использовали C++ sdk на сайте Aws (https://github.com/awslabs/amazon-kinesis-video-streams-producer-sdk-cpp) ./kinesis_video_gstreamer_sample_app имя потока Я пр…
19 апр '20 в 22:38
0
ответов
Camel Kinesis игнорирует параметр maxResultsPerRequest
Camel/Kinesis, похоже, игнорирует maxResultsPerRequest и жадные параметры, которые я установил в uri. <camelContext xmlns="http://camel.apache.org/schema/blueprint" > <route> <from uri="aws-kinesis://my-stream?maxResult…
27 фев '20 в 11:48
0
ответов
Как погрузить строку как json в поток кинезиса flink с помощью Scala?
Как мы можем создать переменную pojo как json в потоке kinesis flink: val inputStream: DataStream[Array[Byte]] = env.addSource { loadConsumerOrFail(config, jobName) } inputStream.print() val transformedStream: DataStream[String] = inputStream.map { …
16 мар '21 в 23:12
0
ответов
Возврат из конечной точки http lambda более 30 секунд
Мне нужно вернуть много данных из лямбды через http. Это медленный запрос для большого количества данных, который легко превысит 30-секундный лимит. Это не вариант для пейджинга, но это нормально, если запрос будет долгим и медленным. Это должен быт…
04 май '21 в 10:45
1
ответ
AWS kinesis getRecords возвращает пустые записи []
Я играю с кинезисом, пробовал очень простой пример. Шаги, которые я выполнил: Выполнить продюсер, чтобы поместить некоторые записи, которые успешно работают. Ошибка на стороне потребителя при выполнении getRecords. Я попытался изменить все эти метод…
15 июн '21 в 15:53
0
ответов
Как передавать данные о событиях из Kinesis в Pinpoint
Я пытаюсь передать данные о событиях из кинезиса, чтобы точно определить. Но когда я нажимаю кнопку «Выбрать поток Amazon Kinesis», как на картинке, я не могу увидеть созданный мной поток доставки. пожалуйста, может кто-нибудь мне помочь, я устал ис…
15 ноя '21 в 18:21