I am writing a very simple lambda in JS. Its main purpose is to take the message from SQS (that i am triggering manually from AWS console) and then publish to kinesis stream through a put record. I have given…
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…