ezmsg

Messaging and Multiprocessing.

ezmsg is a pure-Python implementation of a directed acyclic graph (DAG) pub/sub messaging pattern based on labgraph which is optimized and intended for use in constructing real-time software. ezmsg implements much of the labgraph API (with a few notable differences), and owes a lot of its design to the labgraph developers/project.

ezmsg is very fast and uses Python's multiprocessing.shared_memory module to facilitate efficient message passing without C++ or any compilation/build tooling.

Installation

pip install ezmsg

Dependencies

Due to reliance on multiprocessing.shared_memory, ezmsg requires minimum Python 3.8.
typing_extensions

Testing ezmsg requires:

pytest
pytest-cov
pytest-asyncio
numpy

Setup (Development)

$ python3 -m venv env
$ source env/bin/activate
(env) $ pip install --upgrade pip
(env) $ pip install -e ".[test]"

(env) $ python -m pytest tests # Optionally, Perform tests

Documentation

https://ezmsg.readthedocs.io/en/latest/

ezmsg is very similar to labgraph, so you might get a primer with their documentation and examples. Additionally, there are many examples provided in the examples/tests directories strewn throughout this repository.

Extensions

See the extension directory for more details