I have a standard AWS architecture to capture data from my source that streams data into Firehose endpoint. Firehose streams data into s3, which again ahs a PUT event that triggers lambda to clean firehose payload, adds metadata etc. and then prepares the final data structure that’s ready for consumption