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).
1 maintainer
Release files for zmq-message-patterns 0.1.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| zmq-message-patterns-0.1.0.tar.gz | 11.3 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| zmq_message_patterns-0.1.0-py2.py3-none-any.whl | Python 2, Python 3 | none | any | Details |
Total release size: 23.4 kB
Release files / zmq-message-patterns-0.1.0.tar.gz
| Download URL | zmq-message-patterns-0.1.0.tar.gz |
|---|---|
| Size | 11.3 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
30015fd5faac1abf4f832267f517fa41b1f7bc04d6cac58f5f5c4bbaf07f8575
|
|
BLAKE2b-256 checksum How to use checksums |
e5fac3f33095f94ebd6704e5cad35ee1ddbe581ec0542465959f3bac8cb7648a
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.13.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.0.1 requests-toolbelt/0.9.1 tqdm/4.28.1 CPython/3.7.3
|
Release files / zmq_message_patterns-0.1.0-py2.py3-none-any.whl
| Download URL | zmq_message_patterns-0.1.0-py2.py3-none-any.whl |
|---|---|
| Size | 12.1 kB |
| Tags | Python 2 Python 3 |
|
SHA-256 checksum How to use checksums |
c12a8bd2e61614a33705d9aa9efbcaa6f4ac28015f06e933db1d3ae4de03415f
|
|
BLAKE2b-256 checksum How to use checksums |
60a5c596cc40f5e8885fbf63d9e5f865a98e4e5bd90f0e0e754b250994bbe2bf
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.13.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.0.1 requests-toolbelt/0.9.1 tqdm/4.28.1 CPython/3.7.3
|
