Sample code to append additional information (e.g. Security Group IDs and geolocation data) to VPC Flow Logs for analysis in Elasticsearch.

AWS Kinesis plugin for Filebeat

Data Pipeline for CDC data from MySQL DB to Amazon OpenSearch Service through Amazon Kinesis using Amazon Data Migration Service(DMS).

Ingestion of bid requests through Amazon Kinesis Firehose and Kinesis Data Analytics. Data lake storage with Amazon S3. Restitution with Amazon QuickSight and CloudWatch. 📉

A wrapper around AWS Kinesis Firehose with retry logic and custom queuing behavior. Requires node >= 6.0.0

Analyzing Twitter in real time with Kinesis, Lambda, Comprehend and ElasticSearch

Describes the concepts of lambda architecture and the actual deployment process with an example of building a serverless business intelligence systems using Amazon Kinesis, S3, Athena, OpenSearch Service, and QuickSight.

A simple, practical, and affordable system for measuring head trauma within the sports environment, subject to the absence of trained medical personnel made using Amazon Kinesis Data Streams, Kinesis Data Analytics, Kinesis Data Firehose, and AWS Lambda

Collect, process, and analyze log data using Amazon Kinesis and Elasticsearch Service

Use AWS to stream and analyze the sentiment of live tweets from Twitter based on a certain keyword.

The data preprocessing code for FIREBALL

Scrapped tweets using twitter API (for keyword ‘Netflix’) on an AWS EC2 instance, ingested data into S3 via kinesis firehose. Used Spark ML on databricks to build a pipeline for sentiment classification model and Athena & QuickSight to build a dashboard

Streaming data pipeline to continuously load data from an Amazon MSK or MSK Serverless cluster to Amazon S3 using Amazon Kinesis Data Firehose.

AWS Kinesis Firehose: Apache Log to JSON

The CloudFormation Resource Provider Package For Amazon Kinesis Data Firehose

An embedded Java mock for AWS Kinesis Firehose

Big Data Lab | Stream Delivery AWS Kinesis Firehose

AWS kinesis data stream, kinesis data firehose, a transformer with lambda and store into s3 bucket

❄️ Stream real-time data into Snowflake with Amazon Kinesis Firehose

Streaming and real-time analysis of Twitter data through an AWS data stream