1.the-momentum / open-wearables
Self-hosted platform to unify wearable health data through one AI-ready API.
- wearables
- apple-health
- apple-watch
- fitness
- fitness-analysis
- fitness-api
- +9 more
Ranked by Attention Score: stars gained over the last 90 complete days
99 repositories by Attention Score · Aug 6, 2026 – Nov 3, 2026 (UTC)
Self-hosted platform to unify wearable health data through one AI-ready API.
🌸 Run LLMs at home, BitTorrent-style. Fine-tuning and inference up to 10x faster than offloading
The open source and enterprise-ready webhooks service 🦀
Building event-driven applications the easy way in Go.
1 Line of code data quality profiling & exploratory data analysis for Pandas and Spark DataFrames.
Keep passwords and other sensitive information out of your chat logs and inboxes.
A light-weight, flexible, and expressive statistical data testing library
Meltano: the declarative code-first data integration engine that powers your wildest data and ML-powered product ideas. Say goodbye to writing, maintaining, and scaling your own API integrations.
An ultra-lightweight and blazing-fast Messaging Bus/MQTT Broker for Edge & SDV
A realtime distributed messaging platform
Lightweight and extensible compatibility layer between dataframe libraries!
The fully compliant, embeddable high-performance Go MQTT v5 server for IoT, smarthome, and pubsub
Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
🥊 Tiny 200 byte functional event emitter / pubsub.
A framework for building messaging apps with .NET and C#.
Open-source low code data preparation library in python. Collect, clean and visualization your data in python with a few lines of code.
Dashboard and code-driven configuration for Laravel queues.
[Go]Distributed Actor/Grain framework for Golang with goodies
Barebone MQTT broker that can run on any stream server, the node way
A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
Write your pipelines in C# !
Sync data from one Postgres database to another
Utils for streaming large files (S3, HDFS, gzip, bz2...)
A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program
Clean APIs for data cleaning. Python implementation of R package Janitor
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
An easy to use .NET API for RabbitMQ
A lightweight stream processing library for Go
iWF is a Workflow-As-Code microservice orchestration platform offering an orchestration coding framework and service for building resilient, fault-tolerant, scalable long-running processes
state machine which runs code
Compare tables within or across databases
Microsoft Graph Engine
Trill is a single-node query processor for temporal or streaming data.
Gmqtt is a flexible, high-performance MQTT broker library that fully implements the MQTT protocol V3.x and V5 in golang
Fast ring-buffer deque (double-ended queue)
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
Workflow Automation Engine
C++11 thread-safe container for sharing data between threads (synchronized queue)
PySpark test helper methods with beautiful error messages
Type-safe, persistent, embedded task queues and background job runner w/ SQLite. Web monitoring UI included.
A lightweight opinionated ETL framework, halfway between plain scripts and Apache Airflow
Microservice native message and event store for Postgres
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
.NET event sourced domain driven design model via NServiceBus and GetEventStore
Modular .NET messaging for commands, queries, events, durable inbox and outbox processing, sagas, and broker transports.
GoEventBus — high-performance event bus with a decision layer.
A detective for your data. Zero-config data quality monitoring — works with dbt, Postgres, BigQuery, Snowflake. No YAML.
📜 A CLI toolkit for extracting and working with your digital history
ETL framework for .NET (Parser / Writer for CSV, Flat, Xml, JSON, Key-Value, Parquet, Yaml, Avro formatted files)
🚃 A library for handling mediator patterns and simplified CQRS patterns within an event-driven architecture, inspired by csharp MediatR library.
🍴 Web applications made easy. Since 2011.
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Messenger Clone - Real-time iOS Chat with Firebase Firestore written in Swift
Task management system based on .NET 8 with Microservices, DDD, CQRS, Event Sourcing and Testing Concepts
RedisSMQ: A high-performance Redis message queue for Node.js
.NET Stream Processing Library for Apache Kafka 🚀
Simple but powerful DAG scheduler and dashboard
A powerful background job processing library for Clojure
Messaging APIs for multi-platform
Easy pipelines for pandas DataFrames.
Event Sourcing and CQRS in practice.
An Apache Spark framework for easy data processing, extraction as well as derivation for web archives and archival collections, developed at Internet Archive.
Data-mining and Visualization components for RAD Studio
Big Data essentials: Hadoop, MapReduce, Spark. Explore tutorials and demos in Jupyter notebooks—most are self-contained and live, ready to run with a click.
A type-safe queue for background tasks using PocketBase.
Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets
A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.
Blazingly fast data comparison tool for Python, powered by Rust. Compare massive CSV/Parquet datasets instantly.
Import CSV and JSON into PostgreSQL the easy way
Performant pure-PHP AMQP (RabbitMQ) sync/async (ReactPHP) library
:surfer: Traceable, extendable and minimalist **event bus** implementation for Elixir with built-in **event store** and **event watcher** based on ETS.
Cross-platform beanstalkd queue server admin console.
PipelinR is a lightweight command processing pipeline ❍ ⇢ ❍ ⇢ ❍ for your Java awesome app.
A state-of-the-art distributed system using Reactive DDD as uncertainty modeling, Event Storming as subdomain decomposition, Event Sourcing as an eventual persistence mechanism, CQRS, Async Projections, Microservices for individual deployable units, Event-driven Architecture for efficient integration, and Clean Architecture as domain-centric design
Sample implementation and comparison of various approaches to building DDD applications. Useful as a baseline to quickly start a DDD dot net project.
Monad, Functional Programming features for Golang
RSS as RESTful. This service allows you to transform RSS feed into an awesome API.
Queue plugin for CakePHP - simple, pure PHP and without dependencies.
An effort to bring Google's Firebase C++ API to Qt + QML
Go simple async message bus
Silverback is a message bus and broker integration library for .NET. It is designed to simplify event-driven architectures and asynchronous messaging, with first-class support for Apache Kafka and MQTT.
Daggy - Data Aggregation Utility and C/C++ developer library for data streams catching
An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.
Distributed batch data processing framework
🐇 CLI tool for websockets and Go package
EtlKit is a lightweight ETL (extract · transform · load) library and data integration toolbox for .NET. Build your own data pipelines programmatically in C# — readable, testable, and tracked in source control like the rest of your code.
An Object Pascal Client for NATS
Production-grade Server-Sent Events (SSE) for Fiber v3. Event coalescing, priority lanes, topic wildcards, adaptive throttling, built-in auth, Prometheus metrics, graceful drain.