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

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.

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

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

The CloudFormation Resource Provider Package For Amazon Kinesis Data Firehose

An embedded Java mock for AWS Kinesis Firehose

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

Lightweight and simple Python package to quickly send JSON data to various AWS services.

The data preprocessing code for FIREBALL

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

Let's analyze twitter sentiments.This project uses Twitter API and AWS kinesis,AWS kinesis Firehose,Comprehend,Lambda,S3 and DynamoDB

Resources for AWS Big data certification preparation

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

AWS Kinesis Firehose: Apache Log to JSON

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

Cloud Development Kit (AWS CDK) using TypeScript, Python and Java