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
Metadata
1 maintainer
Release files for pipekit 0.3.5
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| pipekit-0.3.5.tar.gz | 17.2 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| pipekit-0.3.5-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 36.9 kB
Release files / pipekit-0.3.5.tar.gz
| Download URL | pipekit-0.3.5.tar.gz |
|---|---|
| Size | 17.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
2686edc1bedcec03554235489023e80cf0a48946c1cdba0b2f78e835c7b6e864
|
|
BLAKE2b-256 checksum How to use checksums |
3f2a0949d027f29a6e30d9c33ddaeb56cdb14bfb662d9f1b7e4b7fcde003e3ad
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is 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
|
Release files / pipekit-0.3.5-py3-none-any.whl
| Download URL | pipekit-0.3.5-py3-none-any.whl |
|---|---|
| Size | 19.8 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
d82c64543d639816128778a0ff590265a034eda59b98404929a072141d36e9c0
|
|
BLAKE2b-256 checksum How to use checksums |
43d57bde7217a9e4f75ad1df03afa63b62e6ef1d292b2c3a0e2f5985f467d555
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is 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
|
