Library to quickly build ZeroMQ based applications.
Project description
Library to quickly build ZeroMQ based Python applications.
Introduction
Library to make writing applications using ZeroMQ message patterns through PyZMQ easier.
TODO: explain ZMessage and ZNode classes.
Pipeline
A ventilator sends jobs to multiple worker processes, which send the results to a sink.
Channels:
ventilator -> worker: jobs for the workers
ventilator -> sink: IDs of jobs sent to workers, so sink knows if all jobs have completed
worker -> sink: results
sink -> worker: sink sends shutdown command, when finished
Diagram:
ventilator-------------+ | | +-------+------+ | | | | | worker worker worker ... | || || || | ++------++----++ | || | sink----------------+
An is a fully functional example in the examples directory (examples/pipeline_example.py).
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for zmq-message-patterns-0.1.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 30015fd5faac1abf4f832267f517fa41b1f7bc04d6cac58f5f5c4bbaf07f8575 |
|
MD5 | df7742086a47e0580415e19d2b847ec5 |
|
BLAKE2b-256 | e5fac3f33095f94ebd6704e5cad35ee1ddbe581ec0542465959f3bac8cb7648a |
Hashes for zmq_message_patterns-0.1.0-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c12a8bd2e61614a33705d9aa9efbcaa6f4ac28015f06e933db1d3ae4de03415f |
|
MD5 | 4dcffb5173b5016f7b4ae698130a310b |
|
BLAKE2b-256 | 60a5c596cc40f5e8885fbf63d9e5f865a98e4e5bd90f0e0e754b250994bbe2bf |