Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably, socket.io, Phoenix.PubSub, SignalR. Set up once and forever.

mahmoud /boltons

Python6.9K514

🔩 Like builtins, but boltons. 250+ constructs, recipes, and snippets which extend (and rely on nothing but) the Python standard library. Nothing like Michael Bolton.

python
utilities
cache
data-structures

asyncapi /spec

JavaScript5.3K383

The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.

asyncapi
reactive
specification
websockets

awslabs /deequ

Scala3.7K585

Deequ is a library built on top of Apache Spark for defining "unit tests for data", which measure data quality in large datasets.

dataquality
spark
unit-testing
scala

onetimesecret /onetimesecret

Ruby3K457

Keep passwords and other sensitive information out of your chat logs and inboxes.

privacy
onetime
secrets
chat

meltano /meltano

Python2.7K277

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.

dataops
dataops-platform
elt
open-source

mauriciosantos /Buckets-JS

JavaScript1.3K110

A complete, fully tested and documented data structure library written in pure JavaScript.

javascript
data-structures
collections
collection

otobus /event_bus

Elixir70443

:surfer: Traceable, extendable and minimalist **event bus** implementation for Elixir with built-in **event store** and **event watcher** based on ETS.

elixir
eventbus
event-sourcing
eventstore

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.

data-analytics
data-cleaning
data-cleansing
data-engineering

1kbgz /tributary

Python46739

Streaming reactive and dataflow graphs in Python

python
python3
stream
data-pipeline

seamusabshere /data_miner

Ruby30518

Download, unpack from a ZIP/TAR/GZ/BZ2 archive, parse, correct, convert units and import Google Spreadsheets, XLS, ODS, XML, CSV, HTML, etc. into your ActiveRecord models. Uses RemoteTable gem internally.

hasura /pgdeltastream

Go25716

Streaming Postgres logical replication changes atleast-once over websockets

postgresql
logical-replication
write-ahead-log
websockets

antirez /redis

C17013

Redis is an in-memory database that persists on disk. The data model is key-value, but many different kind of values are supported: Strings, Lists, Sets, Sorted Sets, Hashes, Streams, HyperLogLogs, Bitmaps.

liquidSVM /liquidSVM

C++719

Support vector machines (SVMs) and related kernel-based learning algorithms are a well-known class of machine learning algorithms, for non-parametric classification and regression. liquidSVM is an implementation of SVMs whose key features are: fully integrated hyper-parameter selection, extreme speed on both small and large data sets, full flexibility for experts, and inclusion of a variety of different learning scenarios: multi-class classification, ROC, and Neyman-Pearson learning, and least-squares, quantile, and expectile regression.

svm
regression
classification
machine-learning

leozz37 /hare

Go5511

🐇 CLI tool for websockets and Go package

sockets
golang
go
network

SchwarzDigits /hypermatch

Go393

hypermatch is a high-performance ⚡ Go library designed for rapid matching of a large number of rules to events. It processes thousands of events per second 🚀 against extensive rule sets in-memory with minimal latency ⏱️.