Pinned Loading

1. iot-elt-airflow-mongo-timescaledb iot-elt-airflow-mongo-timescaledb Public

   Modern ELT for processing IOT smart watch Fitbit data from MongoDB to Timescaledb using Airflow (dbt, dlt).

   Python 2

2. kafka-stream-aggregator kafka-stream-aggregator Public

   Compute aggregate metrics (i.e. EWMA) on Kafka streams with Rust. Use CDC Kafka Connect to stream raw data into Postgres. Monitor RDBMS & queue latencies via pgAdmin/AKHQ.

   Rust 5 1

3. dicom-etl-dagster-snowflake dicom-etl-dagster-snowflake Public

   ETL for processing DICOM files using Dagster, DBT, PySpark and storing data on S3, Snowflake.

   Python 7