Pipekit
Pipekit is a flow-based programming toolkit, with a control layer.
Quick start
Pipekit connects message processors using pipes. Pipes are just a thin layer on top of Queue objects and 0mq sockets, wrapping them under a common API. The basic idea behind this abstraction is the possibility to transparently replace a pipe implementation with another one, with no code change needed in the producers/consumers.
Pipes simply have an input and an output channel; creating and using them is pretty straightforward:
from pipekit import ThreadPipe
# Pipes need to be given a name
mypipe = ThreadPipe('my-pipe')
mypipe.send('Hello world')
print(mypipe.receive())
# Hello worldPipes are iterables, too:
for msg in mypipe:
dosomething(msg)Need a 0mq-based pipe instead?
from pipekit import ZMQPipe
my0mqpipe = ZMQPipe('my-0mq-pipe', address='tcp://*:5555')Alternatively:
from pipekit import Pipe
my0mqpipe = Pipe('my-0mq-pipe', impl='zmq', address='tcp://*:5555')
print(my0mqpipe)
# <pipekit.ZMQPipe object at 0x7fe...>1 maintainer
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
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file pipekit-0.3.5.tar.gz.
File metadata
- Download URL: pipekit-0.3.5.tar.gz
- Upload date:
- Size: 17.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/3.2.0 pkginfo/1.5.0.1 requests/2.23.0 setuptools/49.6.0 requests-toolbelt/0.9.1 tqdm/4.46.1 CPython/3.6.10
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
2686edc1bedcec03554235489023e80cf0a48946c1cdba0b2f78e835c7b6e864
|
|
| MD5 |
d255f34b0e3a63f3e2d487dc4ffe118d
|
|
| BLAKE2b-256 |
3f2a0949d027f29a6e30d9c33ddaeb56cdb14bfb662d9f1b7e4b7fcde003e3ad
|
File details
Details for the file pipekit-0.3.5-py3-none-any.whl.
File metadata
- Download URL: pipekit-0.3.5-py3-none-any.whl
- Upload date:
- Size: 19.8 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/3.2.0 pkginfo/1.5.0.1 requests/2.23.0 setuptools/49.6.0 requests-toolbelt/0.9.1 tqdm/4.46.1 CPython/3.6.10
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
d82c64543d639816128778a0ff590265a034eda59b98404929a072141d36e9c0
|
|
| MD5 |
e404cd6ccfa5f366965635a4914a7c67
|
|
| BLAKE2b-256 |
43d57bde7217a9e4f75ad1df03afa63b62e6ef1d292b2c3a0e2f5985f467d555
|
