Data logistics system enabling real-time pathogen surveillance. Built for the Seattle Flu Study.
- postgres
- postgresql
- python
- infectious-disease
Repository Index
47,133 repositories indexed
481–504 of 533 · Most stars
Simple API for spawning RabbitMQ Producers and Consumers.
- amqp
- elixir
- elixir-lang
- rabbitmq
Async MQTT client for CPython and MicroPython with asyncio support.
- async-python
- asyncio
- embedded
- embedded-systems
Live import all your Google Sheets to your data warehouse
- data-warehouse
- data-vault
- etl
- google-sheets
A general-purpose message and event queuing library for MongoDB
Kafka library for Crystal. Uses librdkafka.
- crystal
- crystal-lang
- kafka
- librdkafka
kafka pascal, freepascal bindings using librdkafka and zeromq
Gatling plugin for Kafka
An Object Pascal Client for NATS
- delphi
- lazarus
- pascal
- linux
Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code
- business-process
- kafka
- kafka-streams
- micorservices
Elixir library to build Plug-like pipelines
- elixir
- pipeline
- plug
Abstraction layer for simple rabbitMQ connection, messaging and administration
A light-weight package for in-app micro batch processing
- batch
- batch-processing
- event-processing
- go
Declarative data quality engine. Define checks in YAML, run anywhere.
- airflow
- anomaly-detection
- data-contracts
- data-quality
Simple MQTT Client.
- mqtt
- client
- mqtt-client
- python
provides a Suricata Eve output for Kafka with Suricate Eve plugin
- suricata
- intrusion-detection
High performant ETL engine written in TypeScript
- data-processing
- etl
- etl-framework
- streaming-data
An event-driven library to manage and simulate Web Monetization.
- monetization
- web-monetization
- event-driven
- simulation
Apache Kafka Ada client library, based off of librdkafka
Common Lisp RabbitMQ client based on IOLib
- rabbitmq
- rabbitmq-client
- amqp
- common-lisp
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.
Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets
Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.
- actor-model
- apache-flink
- distributed-systems
- event-driven
A detective for your data. Zero-config data quality monitoring — works with dbt, Postgres, BigQuery, Snowflake. No YAML.
- anomaly-detection
- bigquery
- cli
- data-engineering