E

ETL

Configuration and data workflows for an instance of Apache Airflow for the DDRplatform

This is a study project built using FastAPI to practice microservice architecture, data normalization techniques, and clean API design.

The service receives raw payloads from different simulated sources and transforms them into a standardized and validated structure.

It centralizes normalization logic and demonstrates how to build a scalable, maintainable, and test-friendly data processing layer.

Solución end-to-end para la migración y análisis de datos utilizando Python, FastAPI, Kafka y PostgreSQL. Implementa un pipeline de datos asíncrono y una API RESTful para analíticas, todo completamente containerizado con Docker Compose para un despliegue fácil y reproducible.

This project/library contains common elements related to ETL processes...

Unified project demonstrating both batch analytics and real-time streaming pipelines with Apache Spark:

Batch (PySpark/Jupyter): Processed S&P 500 stock data, applied transformations, and ran distributed computations.

Streaming (Spark + Kafka): Built a streaming pipeline to consume Kafka topics, process messages in real-time, and visualize outputs.

Deployed using Docker and Jupyter for reproducibility.

Analyzed decades of historical weather station data (1920–1940) using Hadoop MapReduce. Filtered operable stations, computed descriptive statistics (min, max, mean, median), and produced reports/graphs. Designed modular MRJobs to chain tasks together for scalable processing.

Advanced data synchronization framework.

Reporting for MIT Club of Northern California

В данном проекте находятся два задания, написанные на Python и реализующие выполнение цепочек задач (DAG) в среде Airflow

Simulation of a real hospital scenario with a ML model in production

Official weather data ETL for wind energy project evaluation in El Calafate, Argentina.

target-core is a Singer Target which intend to work with regular Singer Tap. The Goal is to use this package as a foundation to build other targets focusing on the core features, reducing the energy spent on maintaining the common parts.

tap-core is a Singer Tap which intend to work with regular Singer Targets. The Goal is to use this package as a foundation to build other taps focusing on the core features, reducing the energy spent on maintaining the common parts.

Quick and dirty pipeline to prepare a dataset for mobility studies, starting from a collection of CDRs.

Live data source that can be used for data engineering, data warehouse and etl development.

A Python extract, transform, load (ETL) pipeline for the CityPulse Smart City dataset.

Amaxa is a new data loader and ETL (extract-transform-load) tool for Salesforce, designed to support the extraction and loading of complex networks of records in a single operation.

Primary repo now on GitHub: https://github.com/davidmreed/amaxa

Beetle aims to be a comprehensive ETL solution for transforming NOSQL data to relational structure.

Process responsible for load data from devops to SSPO.