aws-samples / amazon-kinesis-analytics-beam-taxi-consumerView external linksLinks
Sample Apache Beam pipeline that can be deployed to Amazon Managed Service for Apache Flink. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to Amazon CloudWatch for visualization.
☆47Dec 19, 2025Updated last month
Alternatives and similar repositories for amazon-kinesis-analytics-beam-taxi-consumer
Users that are interested in amazon-kinesis-analytics-beam-taxi-consumer are comparing it to the libraries listed below
Sorting:
- Streaming ETL with Apache Flink and Amazon Kinesis Data Analytics☆65Oct 17, 2023Updated 2 years ago
- Sample Apache Flink application that can be deployed to Kinesis Analytics for Java. It reads taxi events from a Kinesis data stream, proc…☆86Aug 30, 2023Updated 2 years ago
- A walkthrough of setting up a Kinesis Data Analytics for Java Application which ingest streaming JSON data and leverages the Flink Table …☆16Aug 30, 2023Updated 2 years ago
- Learn how to build an end-to-end streaming architecture to ingest, analyze, and visualize streaming data in near real-time☆34Jul 12, 2022Updated 3 years ago
- A Java application that replays events that are stored in objects in Amazon S3 into a Amazon Kinesis stream as if they occurred in real t…☆51Jan 3, 2025Updated last year
- Build your own social media analytics with Apache Kafka☆14Jun 17, 2024Updated last year
- Optimizing downstream data processing with Amazon Kinesis Data Firehose and Amazon EMR running Apache Spark☆14Apr 14, 2023Updated 2 years ago
- Flink KDA Sample Application☆14Mar 22, 2021Updated 4 years ago
- Leveraging Amazon Application Auto Scaling you have now the possibility to interact to custom resources in order to automatically handle …☆29Jul 22, 2021Updated 4 years ago
- This library contains various Apache Flink connectors to connect to AWS data sources and sinks.☆16Dec 5, 2023Updated 2 years ago
- Database schema management in a serverless way☆12Jun 12, 2024Updated last year
- Validate the fitness of your AWS solutions, without the heavy lifting!☆15Sep 2, 2023Updated 2 years ago
- Example applications in Java, Python and SQL for Kinesis Data Analytics, demonstrating sources, sinks, and operators.☆147May 21, 2024Updated last year
- Design best practices for building scalable ETL (Extract-Transform-Load) and ELT (Extract-Load-Transform) data processing pipelines using…☆17Dec 8, 2019Updated 6 years ago
- Snapshot manager for Amazon Kinesis Data Analytics for Apache Flink helps the users to generate a snapshot on a periodic basis.☆19Aug 30, 2023Updated 2 years ago
- A Step Functions microservice for remediating GuardDuty findings.☆18Nov 7, 2022Updated 3 years ago
- Vector Embedding Server in under 100 lines of code☆22Mar 1, 2024Updated last year
- ☆21Aug 25, 2024Updated last year
- ☆21Dec 19, 2025Updated last month
- ☆12Jun 26, 2022Updated 3 years ago
- A self-paced workshop designed to allow you to get hands on with building a real-time data platform using serverless technologies such as…☆22Dec 3, 2018Updated 7 years ago
- A composable framework for fast and scalable data analytics☆57Dec 12, 2022Updated 3 years ago
- Central hub for learning, using, and mastering Amazon Verified Permissions (AVP) and Cedar.☆25Apr 24, 2024Updated last year
- Pattern generator and debugging tool for Amazon EventBridge☆25Mar 24, 2024Updated last year
- Ship The Right Solution Faster☆25Dec 31, 2025Updated last month
- How query engine work golang port for learning purpose☆23Dec 25, 2021Updated 4 years ago
- ☆11Sep 14, 2022Updated 3 years ago
- Demo illustrating how to run Quarkus application on Knative Eventing with Kafka and Funqy modules☆26Updated this week
- The Github Actions - AWS CDK Lambda Monorepo Starter is a comprehensive template designed for efficiently building and deploying multiple…☆11Dec 22, 2023Updated 2 years ago
- ☆33Jun 11, 2025Updated 8 months ago
- Cookiecutter template for new Serverless services - CDK deployment code, pipeline and handler are covered with best practices built in.☆37Jan 12, 2026Updated last month
- ☆11Jun 12, 2023Updated 2 years ago
- Niagara Summit 2016 example code demonstrating the process of migrating a module from AX to N4.☆10May 13, 2016Updated 9 years ago
- Sample AWS Lambda function written in Java that connects to a DB via JDBC☆12Jun 30, 2015Updated 10 years ago
- Webscraping apartments.com with Python☆10Aug 10, 2018Updated 7 years ago
- Niagara weather module for Open Weather Map provider☆15Jan 12, 2020Updated 6 years ago
- AWS CDK Serverless Toolsuite☆87Updated this week
- Repository for the dbt Semantic Layer course☆11Nov 13, 2025Updated 3 months ago
- Sample code for the AWS Big Data Blog Post Building a scalable streaming data processor with Amazon Kinesis Data Streams on AWS Fargate☆39Nov 17, 2025Updated 2 months ago