RWaltersMA / mongo-spark-jupyter
Docker environment that spins up MongoDB replica set, Spark, and Jupyter Lab. Example code uses PySpark and the MongoDB Spark Connector.
☆39Updated last year
Related projects: ⓘ
- Docker Airflow - Contains a docker compose file for Airflow 2.0☆56Updated 2 years ago
- A Series of Notebooks on how to start with Kafka and Python☆151Updated last year
- Airflow helm chart for AWS EKS☆18Updated 3 years ago
- ☆30Updated last year
- Repo that relates to the Medium blog 'Keeping your ML model in shape with Kafka, Airflow' and MLFlow'☆120Updated last year
- Create a streaming data, transfer it to Kafka, modify it with PySpark, take it to ElasticSearch and MinIO☆56Updated last year
- ☆35Updated 2 months ago
- A workspace to experiment with Apache Spark, Livy, and Airflow in a Docker environment.☆39Updated 3 years ago
- Data lake, data warehouse on GCP☆54Updated 2 years ago
- The Python fake data producer for Apache Kafka® is a complete demo app allowing you to quickly produce JSON fake streaming datasets and …☆81Updated 4 months ago
- Project for real-time anomaly detection using Kafka and python☆55Updated last year
- Resources for video demonstrations and blog posts related to DataOps on AWS☆166Updated 2 years ago
- A real-time streaming ETL pipeline for streaming and performing sentiment analysis on Twitter data using Apache Kafka, Apache Spark and D…☆29Updated 4 years ago
- Developed a data pipeline to automate data warehouse ETL by building custom airflow operators that handle the extraction, transformation,…☆89Updated 2 years ago
- PySpark Tutorial for Beginners on Google Colab: Hands-On Guide☆16Updated 4 years ago
- Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python☆43Updated last year
- Apache Airflow in Docker Compose (for both versions 1.10.* and 2.*)☆184Updated 9 months ago
- Airflow Tutorials☆24Updated 3 years ago
- Delta-Lake, ETL, Spark, Airflow☆42Updated last year
- Produce Kafka messages, consume them and upload into Cassandra, MongoDB.☆36Updated 11 months ago
- ☆38Updated this week
- This project helps me to understand the core concepts of Apache Airflow. I have created custom operators to perform tasks such as staging…☆69Updated 5 years ago
- Project files for the post: Running PySpark Applications on Amazon EMR using Apache Airflow: Using the new Amazon Managed Workflows for A…☆41Updated 2 years ago
- (project & tutorial) dag pipeline tests + ci/cd setup☆84Updated 3 years ago
- Kafka variant of the MLOps Level 1 stack☆22Updated 2 years ago
- The practical use-cases of how to make your Machine Learning Pipelines robust and reliable using Apache Airflow.☆52Updated last year
- Mastering Big Data Analytics with PySpark, Published by Packt☆153Updated last month
- ☆22Updated 3 years ago
- ☆36Updated 4 years ago
- Apche Spark Structured Streaming with Kafka using Python(PySpark)☆41Updated 5 years ago