jaumpedro214 / traffic-flow-spark-kafka
Testing Spark Structured Streaming anf Kafka with real data from traffic sensors
☆16Updated 2 years ago
Alternatives and similar repositories for traffic-flow-spark-kafka:
Users that are interested in traffic-flow-spark-kafka are comparing it to the libraries listed below
- Simple stream processing pipeline☆99Updated 9 months ago
- build dw with dbt☆43Updated 5 months ago
- ☆40Updated 8 months ago
- End to end data engineering project☆53Updated 2 years ago
- Design/Implement stream/batch architecture on NYC taxi data | #DE☆25Updated 3 years ago
- Project for "Data pipeline design patterns" blog.☆45Updated 7 months ago
- Data Engineering Capstone Project: ETL Pipelines and Data Warehouse Development☆21Updated 5 years ago
- Create a streaming data, transfer it to Kafka, modify it with PySpark, take it to ElasticSearch and MinIO☆59Updated last year
- ☆12Updated 3 years ago
- This project demonstrates how to use Apache Airflow to submit jobs to Apache spark cluster in different programming laguages using Python…☆41Updated last year
- Produce Kafka messages, consume them and upload into Cassandra, MongoDB.☆40Updated last year
- ☆37Updated 5 years ago
- Simple ETL pipeline using Python☆25Updated last year
- This project focuses on building a robust data pipeline using Apache Airflow to automate the ingestion of weather data from the OpenWeath…☆21Updated last year
- Delta-Lake, ETL, Spark, Airflow☆46Updated 2 years ago
- A Postgres data warehouse for processing synthetic data using IAC principles☆16Updated 2 years ago
- Simplified ETL process in Hadoop using Apache Spark. Has complete ETL pipeline for datalake. SparkSession extensions, DataFrame validatio…☆53Updated last year
- A list of all my posts and personal projects☆70Updated 9 months ago
- ☆21Updated 2 years ago
- A production-grade data pipeline has been designed to automate the parsing of user search patterns to analyze user engagement. Extract d…☆24Updated 3 years ago
- Example repo to create end to end tests for data pipeline.☆22Updated 9 months ago
- Project for real-time anomaly detection using Kafka and python☆58Updated 2 years ago
- ☆38Updated last year
- This project aims to build a streaming application to perform real-time analytics of Covid-19 related tweets and deploy an ML model for r…☆13Updated 3 years ago
- A real-time streaming ETL pipeline for streaming and performing sentiment analysis on Twitter data using Apache Kafka, Apache Spark and D…☆30Updated 4 years ago
- A self-contained, ready to run Airflow ELT project. Can be run locally or within codespaces.☆66Updated last year
- Source code for the Apache Kafka in Python video series☆19Updated 3 years ago
- ☆64Updated last week
- A batch processing data pipeline, using AWS resources (S3, EMR, Redshift, EC2, IAM), provisioned via Terraform, and orchestrated from loc…☆21Updated 2 years ago
- RedditR for Content Engagement and Recommendation☆21Updated 7 years ago