Skip to main content

High level implementation of the pipeline task distribution pattern with ZeroMQ

Project description

A high level pipeline pattern implemented in Python with ZeroMQ.

Pipeline is a data and task distribution pattern for distributed and parallel computing. This implementation abstracts away many details of ZeroMQ while keeping all the performance advantages the framework offers.

This library focuses more on task distribution than data distribution, since distributing data creates a memory bottleneck and tends not to scale well.

Client workers are responsible for both retrieval and processing of data in this implementation.

Github repository: https://github.com/ailling/py-zmq-pipeline

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

py-zmq-pipeline-0.1.7.tar.gz (10.9 kB view details)

Uploaded Source

File details

Details for the file py-zmq-pipeline-0.1.7.tar.gz.

File metadata

File hashes

Hashes for py-zmq-pipeline-0.1.7.tar.gz
Algorithm Hash digest
SHA256 60060a460b8ad706225959af687bb771f55f52837bedca6cff4659b4ac4c8899
MD5 147927c25c19a9c44fb30b0f1ce1dd93
BLAKE2b-256 6bdb1229cfb3461e47517cca3af2b4e508c74ebf6bcdad0cfad9d0a106f047e5

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page