Questions tagged [apache-camel-aws-kinesis]

13 questions
5
votes
1 answer

How to decode AWS Kinesis Video Stream GetMedia API output to mp3/wav?

I ingested data to (Kinesis Video Stream) KVS via AWS Connect service now using GetMedia API am able to extract the Payload but how can I convert this output to a mp3/wav ? I want to ingest this output to AWS Transcribe service to get text format of…
2
votes
1 answer

Using Apache Camel AWS-KINESIS endpoint, how do I checkpoint the message in the Kinesis stream?

I use AWS-KINESIS endpoint in Camel to read from a AWS Kinesis contentstream. I can read messages just fine, but how do I checkpoint the message on the stream? In the standard AWS Kinesis Java client library you have the concept of Workers and…
DKIT
  • 3,471
  • 2
  • 20
  • 24
1
vote
1 answer

AWS kinesis getRecords returns empty Records[]

I'm playing around with kinesis, I have tried very simple example. Steps I have performed: Execute Producer to Put Some records that works successfully. Facing error on the consumer end while executing the getRecords. I have tried to change all…
1
vote
0 answers

aws lambda throws internal lambda error during streaming from kinesis

I am using lambda which uses kinesis stream as trigger . Below are the configuration of the trigger Batch size: 100 Batch window: None Concurrent batches per shard: 2 **Last processing result: PROBLEM: internal Lambda error.** Maximum age of record:…
1
vote
1 answer

Trying to understand WebRTC Signaling Channels

Help me understand how the signaling works in WebRTC. Specifically, if I have a given channel, say using Amazon Kinesis or a similar product, how would a peer know which peer to call? Do I need a dedicated channel per set of all peers that need to…
Mohammad
  • 714
  • 4
  • 13
1
vote
0 answers

Camel Kinesis ignoring maxResultsPerRequest parameter

Camel/Kinesis seems to be ignoring maxResultsPerRequest and greedy parameters that I have set in the uri.
lbenedetto
  • 2,022
  • 1
  • 21
  • 39
0
votes
0 answers

Returning from http lambda endpoint for longer than 30s

I need to return a lot of data from a lambda over http. It's a slow query for a lot of data and will easily exceed the 30s limit. It's not an option to introduce paging but it's okay to be a long slow request. It needs to be a simple GET endpoint.…
0
votes
0 answers

Why use AWS Kinesis, when AWS Lambda can handle the task?

I am new to AWS and I don't understand the use of AWS Kinesis quite well. I know it is used for processing streaming data, but why not just use AWS Lambda to process the incoming data and possibly store them to DB eventually? As a real case…
0
votes
1 answer

AWS kinesis video stream in raspberrypi. Unable to create Kinesis Video stream

I'm trying to stream video from raspberry pie using aws kinesis video stream. We used c++ sdk on the Aws site (https://github.com/awslabs/amazon-kinesis-video-streams-producer-sdk-cpp) ./kinesis_video_gstreamer_sample_app stream name I try this.…
0
votes
0 answers

Lambda function triggering more than once

I am trying to create the following architecture on AWS. AWS architecture I have 3 devices connected to Iot core: -Thermometer -Air conditioner -Lambda function Thermometer should send the temperature every 5 seconds to the Core, then the telemetry…
0
votes
1 answer

Trigger AWS lambda for specific Kinesis event push

I am new in AWS lambda area. I am creation a function which will consume Kinesis events. But I want to trigger my lambda function when specific event get push to kinesis (not for all events push to Kinesis). Is there a way that I can configure a…
0
votes
1 answer

Kinesis Agent Input - Log file created for each day

New Log file is created for each day with date appended in the name. For example "data_log-2017-05-14" log file is created for 14th May. I need to set up Kinesis Agent to read data from the logs generated. But since each day a new log file is…
-3
votes
1 answer

AWS Kinesis, Is S3 mandatory to be used for kinesis?

Could you please provide some clarity on s3 usage in Kinesis? Thanks, Subham