Cdc Python Packages

epiweeks

Epidemiological weeks calculation based on CDC (MMWR) and ISO week numbering systems

mq-bridge-py

Async Rust library to route messages between Kafka, NATS, MQTT, AMQP, databases and HTTP, with Python and Node bindings

dbt-materialize

The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL

mq-bridge-py-basic

Async Rust library to route messages between Kafka, NATS, MQTT, AMQP, databases and HTTP, with Python and Node bindings

mq-bridge

Async Rust library to route messages between Kafka, NATS, MQTT, AMQP, databases and HTTP, with Python and Node bindings

duckle

Open-source ETL/ELT you deploy on your own servers or cloud. Built on DuckDB: no-code/low-code visual pipelines or SQL, 385 components, dbt, CDC, data quality, reverse ETL, lineage, MCP for AI agents. No vendor cloud, no per-row billing.

pgchangefeed

Durable change feeds for PostgreSQL, powered by logical replication.

mq-bridge-basic

Async Rust library to route messages between Kafka, NATS, MQTT, AMQP, databases and HTTP, with Python and Node bindings

commons-codec

Data decoding, encoding, conversion, and translation utilities.

r2g-arango

Project relational and structured data sources as a graph in ArangoDB. Materialize via batch ETL, sync via CDC/Kafka, or query through the mapping studio. PostgreSQL and Snowflake supported today.

mysql-event-stream

Lightweight CDC engine for MySQL and MariaDB binlog — with Node.js and Python bindings.

omni-box

Unified transactional messaging (Outbox & Inbox) library for async Python applications

onecdc

Выгрузка данных 1С по технологии CDC (загрузка изменений данных)

rivven

A high-performance distributed event streaming platform written in Rust. Lightweight binaries. Zero runtime dependencies. Sub-second startup.

data-platfrom-deployer

CLI tool for automatic data platform deployment

phenodata

Acquire and process open access phenology data.

drasi-agent-router-contracts

The Data Change Processing platform

seedbraid

Open-source toolkit for lossless, reference-based reconstruction of large binary artifacts using deterministic CDC and compact SBD1 seeds.

cdcanary

🐤 A canary for your CDC pipeline — catches silent replication drift (row counts, freshness, null rates, schema) between MySQL/PostgreSQL/BigQuery before your analysts do

csv-cdc

A high-performance Change Data Capture (CDC) tool for comparing CSV files and detecting differences. Built with Python and optimized for speed using Polars, NumPy, and xxHash.

pyspark-cdc

A Python library for Change Data Capture (CDC) workflows using PySpark.

pgstream

Python SDK for Postgres CDC — stream WAL changes to vector stores (pgvector, Qdrant) in real time.

pynssp

A Python package for the National Syndromic Surveillance Program (NSSP) and its Community of Practice. A collection of classes and methods to advance the practice of Syndromic Surveillance.

dbqueue

PostgreSQL Logical Replication → RabbitMQ CDC pipeline