101.snowplow / snowplow
The leader in Customer Data Infrastructure
- snowplow
- analytics
- data
- data-pipeline
- data-collection
- product-analytics
- +3 more
Ranked by Attention Score: stars gained over the last 30 complete days
101–200 of 354 by Attention Score · Oct 5, 2026 – Nov 3, 2026 (UTC)
The leader in Customer Data Infrastructure
🔩 Like builtins, but boltons. 250+ constructs, recipes, and snippets which extend (and rely on nothing but) the Python standard library. Nothing like Michael Bolton.
Database Subsetting and Relational Data Browsing Tool.
Copy a Postgres database to a target Postgres server (pg_dump | pg_restore on steroids)
GoDS (Go Data Structures) - Sets, Lists, Stacks, Maps, Trees, Queues, and much more
Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
The Cloud Native Webhooks Gateway
IoT Platform Framework
Open-source IoT Gateway - integrates devices connected to legacy and third-party systems with ThingsBoard IoT Platform using Modbus, CAN bus, BACnet, BLE, OPC-UA, MQTT, ODBC and REST protocols.
Deequ is a library built on top of Apache Spark for defining "unit tests for data", which measure data quality in large datasets.
Apache Kyuubi is a distributed and multi-tenant gateway to provide serverless SQL on data warehouses and lakehouses.
Micro second messaging that stores everything to disk
Ncurses based XMPP client
DataSphereStudio is a one stop data application development& management portal, covering scenarios including data exchange, desensitization/cleansing, analysis/mining, quality measurement, visualization, and task scheduling.
In-memory message queue with an Amazon SQS-compatible interface. Runs stand-alone or embedded.
A framework for building messaging apps with .NET and C#.
Apache KIE (Knowledge Is Everything) is the home of Drools, OptaPlanner, jBPM, and Kogito.
Apache Ignite
AI Infra / AI Orchestration / AI Control Plane
A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases. The VerneMQ mission is active & the project maintained. Thank you for your support!
A cluster computing framework for processing large-scale geospatial data
Lightweight data stream processing engine for IoT edge
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
pmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].
Maxwell's daemon, a mysql-to-json kafka producer
Utils for streaming large files (S3, HDFS, gzip, bz2...)
RabbitMQ .NET client for .NET Standard 2.0+ and .NET 4.6.2+
Open-source low code data preparation library in python. Collect, clean and visualization your data in python with a few lines of code.
🔥🔥🔥 Open source Reverse ETL - alternative to hightouch and census.
Nessie: Transactional Catalog for Data Lakes with Git-like semantics
ChatLayout is an alternative solution to MessageKit. It uses custom UICollectionViewLayout to provide you full control over the presentation as well as all the tools available in UICollectionView. It supports dynamic cells and supplementary view sizes.
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Deepchecks: Tests for Continuous Validation of ML Models & Data. Deepchecks is a holistic open-source solution for all of your AI & ML validation needs, enabling to thoroughly test your data and models from research to production.
A modern high-performance open source message queuing system
Concurrent and multi-stage data ingestion and data processing with Elixir
Barebone MQTT broker that can run on any stream server, the node way
The ultimate distributed MQTT broker. Handles 100M+ connections and 10M msg/sec with ease. Built on Kafka to provide industrial-grade persistence and eliminate data loss.
Tenzir is the data pipeline engine for security teams.
Real-time monitor and web admin for Celery distributed task queue
Franz is a free messaging app for services like WhatsApp, Slack, Messenger and many more.
Kubernetes-native platform to run massively parallel data/streaming jobs
:bus: Simple and lean service bus implementation for .NET
Python Streaming DataFrames for Kafka
Pandas, Polars, Spark, and Snowpark DataFrame comparison for humans and more!
Desbordante is a high-performance data profiler that is capable of discovering many different patterns in data using various algorithms. It also allows to run data cleaning scenarios using these algorithms. Desbordante has a console version and an easy-to-use web application.
Kroxylicious, the snappy open source proxy for Apache Kafka®
Luigi is a Python module that helps you build complex pipelines of batch jobs. It handles dependency resolution, workflow management, visualization etc. It also comes with Hadoop support built in.
Generic command line non-JVM Apache Kafka producer and consumer
Sync data from one Postgres database to another
Messaging library for Python.
Clean APIs for data cleaning. Python implementation of R package Janitor
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
Karapace - Your Apache Kafka® essentials in one tool
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
CMAK is a tool for managing Apache Kafka clusters
Fast, efficient, and scalable distributed map/reduce system, DAG execution, in memory or on disk, written in pure Go, runs standalone or distributedly.
A lightweight stream processing library for Go
MongooseIM is Erlang Solutions' robust, scalable and efficient XMPP server, aimed at large installations. Specifically designed for enterprise purposes, it is fault-tolerant and can utilise the resources of multiple clustered machines.
Apache InLong - a one-stop, full-scenario integration framework for massive data
Ultra quick message queue and streaming server
🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊
Fast ring-buffer deque (double-ended queue)
Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.
The idiomatic asyncio MQTT client
Write your pipelines in C# !
.NET event sourced domain driven design model via NServiceBus and GetEventStore
[Go]Distributed Actor/Grain framework for Golang with goodies
Modular, Production-Ready, Open-Source EHR
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
🥊 Tiny 200 byte functional event emitter / pubsub.
Dashboard and code-driven configuration for Laravel queues.
High performance, distributed and low latency publish-subscribe platform.
Apache Linkis builds a computation middleware layer to facilitate connection, governance and orchestration between the upper applications and the underlying data engines.
A 100% native C# implementation of ZeroMQ for .NET
An easy to use .NET API for RabbitMQ
Confluent Schema Registry for Kafka
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
Trill is a single-node query processor for temporal or streaming data.
Logical Replication extension for PostgreSQL 17, 16, 15, 14, 13, 12, 11, 10, 9.6, 9.5, 9.4 (Postgres), providing much faster replication than Slony, Bucardo or Londiste, as well as cross-version upgrades.
An extensible distributed system for reliable nearline data streaming at scale
🏅State-of-the-art learned data structure that enables fast lookup, predecessor, range searches and updates in arrays of billions of items using orders of magnitude less space than traditional indexes
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
Multi-Modal Database replacing MongoDB, Neo4J, and Elastic with 1 faster ACID solution, with NetworkX and Pandas interfaces, and bindings for C 99, C++ 17, Python 3, Java, GoLang 🗄️
A curated list of awesome system integration software and resources.
Home of Quamina, a fast pattern-matching library in Go
An open source, a high-performance hybrid integration platform that allows developers quick integration with any application, data, or system.
High-performance, time-indexed object storage for robotics and industrial IoT
The type-safe, event-driven workflow orchestration library that scales with your business. Build robust, distributed workflows in Go with compile-time safety, automatic retries, and horizontal scaling out of the box. Integrate with your existing tech stack using adapters 🚀
state machine which runs code
A robust web archive analytics toolkit