python-broqer
Data processor
A reactive data processing library with publish-subscribe functionality and asyncio support.
Carefully crafted library to operate with continuous streams of data in a reactive style with publish/subscribe, asyncio support and broker functionality.
74 stars
8 watching
6 forks
Language: Python
last commit: 10 months ago brokerfunctional-programmingpublish-subscribepythonreactive
Related projects:
| Repository | Description | Stars |
|---|---|---|
 quora/asynq | A Python library that simplifies asynchronous programming by allowing batching of requests to external services. | 688 |
 reactivebayes/rocket.jl | A library for reactive programming using Observables in Julia to process asynchronous data | 189 |
 spreads/spreads | A high-performance library for real-time data processing and time series manipulation | 427 |
 dodger487/dplython | A Python implementation of data manipulation functions inspired by the R package Dplyr. | 764 |
 sixty-north/python-transducers | A Python package providing a transducer framework for composing simple reducers into more complex data processing functions. | 55 |
 svenkreiss/pysparkling | A lightweight Python implementation of Spark's RDD and DStream interfaces for improved performance on small datasets | 262 |
 reactivecouchbase/reactivecouchbase-rs-core | Provides a reactive programming model for interacting with NoSQL databases | 26 |
 reubano/meza | A lightweight toolkit for processing tabular data with a focus on functional programming and PyPy compatibility. | 416 |
 reactive-streams/reactive-streams-dotnet | A standard for asynchronous stream processing with non-blocking backpressure in .NET | 198 |
 solid-mechanics/postpro4abq | A Python-based toolkit for post-processing ABaqus simulation files | 9 |
 dankilman/awe | A Python library for building dynamic web-based reports and dashboards | 114 |
 reactivex/rxphp | A set of libraries to compose asynchronous and event-based programs using observable streams. | 1,704 |
 asynkron/wire | A binary serializer that solves the problem of deserializing unknown or malicious types in distributed systems | 376 |
 igrishaev/f | Functional tools for Python data manipulation and computation | 119 |
 reactivemarbles/dynamicdata | A set of reusable operations to manipulate and shape data in a declarative way without directly managing collections. | 1,734 |