186 dependents
Package Description Downloads/month
Python Library for Accessing the Cohere API 38.3M
Apache Beam SDK for Python 7.8M
Generate Avro Schemas from Python classes. Serialize/Deserialize python instance... 1M
Python Rest Client to interact against Schema Registry confluent server 555K
💻 A fully functional local AWS cloud stack. Develop and test your cloud & Server... 504K
Apache Avro <-> pandas DataFrame 275K
Apache Airflow - A platform to programmatically author, schedule, and monitor wo... 160K
Apache Flink Python API 156K
Apache Airflow - A platform to programmatically author, schedule, and monitor wo... 138K
Use the AWS Glue Schema Registry in Python projects. 134K
Open edX events from the Hooks Extensions Framework 108K
Framework for Task orchestration 73K
An Avro SerDe implementation that integrates with the confluent schema registry ... 57K
Abacus.AI Python Client Library 30K
A Swiss Army knife for enabling simple ETL operations 28K
FINTER API 13K
Python api utils 8K
[Archived] Move to agentsociety 8K
A modular data preparation CLI for ingestion, profiling, classification, preproc... 6K
Package to interact with the Highlighter Perception System 5K
A pub-sub client library for Multimessenger Astrophysics. 5K
An opinionated Kafka producer/consumer built on top of confluent-kafka-python/li... 5K
Singer.io encodings library 5K
A CKAN extension providing a versioned datastore using MongoDB and Elasticsearch... 5K
Python SDK for PFB format 4K
Repository for yaq core python packages. 4K
Asyncio-based Python library for working with aiokafka, Confluent Schema Registr... 4K
ZTF-specific implementations for Ampel 4K
Utilities to handle BP/RP (XP) Gaia low-resolution spectra as delivered via the ... 4K
The power of librdkafka for pythons 3K
Metaflow Functions 3K
🐍 Minos is a framework which helps you create reactive microservices in Python 3K
HsPyLib - Apache Kafka Manager 3K
A data transformation library for flattening complex nested structures into tabu... 3K
Interface with OSDU RDDMS using ETP protocol 3K
Use bacpipe to streamline the process of generating embeddings and analysing you... 3K
A Kafka mock library that is designed to be used in integration tests for applic... 3K
Oppfolging python package for DWH ETL 3K
Nacre 2K
Tabsdata is a publish-subscribe (pub/sub) server for tables. 2K
Build microservices in Jupyter 2K
A library for converting avro schemas to python types. 2K
LSST plugin for AMPEL 2K
CLI data plumbing tool 2K
Rand Engine v2. Package with some methods to generate random data in different f... 2K
A modern, production-ready Python logging framework with zero configuration. 2K
Literp Format Python Lib 2K
Enterprise Data Trust — Chapter 4: Unified Drift Monitoring Application 2K
Data intensive science for everyone. 2K
Modular Image Reduction and Analysis Resource (MIRAR) 2K