流和管道处理服务
项目描述
用于为数据流、事件和块创建和运行处理管道的服务和框架。pypelined的管道由使用chainlet库的各个元素组成。它们构建在 Python 配置文件中，来自自定义对象或预定义插件。
import chainlet
from pypelined.conf import pipelines
@chainlet.funclet
def add_time(chunk):
chunk['tme'] = time.time()
return chunk
process_chain = Socket(10331) >> decode_json() >> stop_if(lambda value: value.get('rcode') == 0) >> \
add_time() >> Telegraf(address=('localhost', 10332), name='chunky')
pipelines.append(process_chain)一旦运行，pypelined以事件驱动的方式驱动其所有处理管道。
下载文件
下载适用于您平台的文件。如果您不确定要选择哪个，请了解有关安装包的更多信息。
源分布
pypelined-0.1.3.tar.gz
（14.0 kB
查看哈希）
内置分布
pypelined-0.1.3-py2.py3-none-any.whl
（21.6 kB
查看哈希）