What I am trying to achieve is the following. In Amazon Connect, when I create a Flow with Start Streaming Data block, it starts streaming to a Kinesis Video Stream, and I can call a lambda function with the streams…
I have a lambda processing kinesis events. Kinesis has 3 retries in case of failure. The lambda process the events properly but it is called 4 times. I have looking for what can be the cause and I have found…
I have intermediate AWS knowledge and have an issue, where I can see multiple ways of solving it, and I'm looking for opinions from more skilled AWS architects. I have an on-premise system that produces ~30k XML files (each <100KB)…
My goal is to read data from kinesis and upload csv file on s3, but in csv file arrow(=>) is coming in json data insted of colon(:) Logstash config file input { kinesis { application_name => "logstash" kinesis_stream_name => "events"…
I have a node app that puts events into a kinesis stream. If the partition key is different, is it possible for those 2 events to go into the same shard? The kinesis is configured to be on-demand
Its very simple. This code works as jar and lambda (maven project): package test2; import java.util.Map; import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.RequestHandler; public class test implements RequestHandler<Map<String,String>, String>{ @Override public String handleRequest(Map<String,String> event, Context context) { String prueba = "Prueba"; return prueba;…
In Amazon Connect, I create a Flow with Start Streaming Data block. I have verified that calls trigger live audio streams through Kinesis Video Streams. See the ARNs below (captured by calling AWS CLI command aws resourcegroupstaggingapi get-resources). { "ResourceTagMappingList":…
I have a s3 bucket with some 10M objects which all needs to be processed and sent to opensearch. To this end I am evaluating if kenisis can be used for this. The solutions online seem to imply using lambda,…
Where I'm At I have a simple node.js kinesis data stream consumer that consumes iot data from various devices. Oftentimes, these are coming from more than 250 devices every 15 seconds, which means a high-volume of json is streaming into…
Here is my code KinesisClient kinesisClient = KinesisClient.builder().build(); PutRecordRequest putRecordRequest = new PutRecordRequest(); putRecordRequest.setStreamName("stream-name"); putRecordRequest.setPartitionKey("SomeString-" + UUID.randomUUID()); putRecordRequest.setData(ByteBuffer.wrap(data)); PutRecordResponse putRecordResponse = kinesisClient.putRecord(putRecordRequest); For some strange reason it's saying it can't resolve the putRecord(PutRecordRequest) method even though it's clearly there when…