Metadata-Version: 2.1
Name: zmq-message-patterns
Version: 0.1.0
Summary: Library to quickly build ZeroMQ based applications.
Home-page: https://github.com/dansan/python-zmq-message-patterns/
Author: Daniel Tröder
Author-email: daniel@admin-box.com
License: MIT
Project-URL: Bug Reports, https://github.com/dansan/python-zmq-message-patterns/issues/
Project-URL: Source, https://github.com/dansan/python-zmq-message-patterns/
Keywords: zmq zeromq pyzmq sockets development parallel-processing concurrency
Platform: UNKNOWN
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: Topic :: Software Development :: Libraries
Classifier: Topic :: System :: Networking
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 2
Classifier: Programming Language :: Python :: 2.7
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.3
Classifier: Programming Language :: Python :: 3.4
Classifier: Programming Language :: Python :: 3.5
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Description-Content-Type: text/x-rst; charset=UTF-8
Requires-Dist: six
Requires-Dist: pyzmq

python-zmq-message-patterns
===========================

Library to quickly build ZeroMQ based Python applications.

Introduction
------------

Library to make writing applications using `ZeroMQ <http://www.zeromq.org/>`_ message patterns through `PyZMQ <https://github.com/zeromq/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``).


