一个小型管道框架
项目描述
picopipe
基于函数构建的小型管道框架
一篇描述picopipe开发和使用的文章: Towards Data Science: The Worlds Smallest Data Pipeline Framework
安装
pip install picopipe
示例
def add1(value):
return value + 1
def add2(value):
return value + 2
def add3(value):
return value + 3
from picopipe import pipeline
p = pipeline(add1, add2, add3)
p([10, 20, 30])
查看测试以获取更多示例。
可视化
with open("pipeline.mmd", "w") as fp:
fp.write(to_mermaid(p))
Mermaid文件(在github中渲染)
flowchart
subgraph pipeline_98e33e0628b546268abb2af5f74e50f1 ["pipeline"]
end
subgraph pipeline_205813c806fd4b37b40309497768f7c1 ["pipeline"]
node0["identity"]
node1["is_not_none"]
node2["identity"]
end
node0 --> node1
node1 --> node2
click node0 console.log "def identity(value):<br/>    return value<br/>"
click node1 console.log "@pfilter<br/>def is_not_none(v):<br/>    return v is not None<br/>"
click node2 console.log "def identity(value):<br/>    return value<br/>"
subgraph pipeline_d2f205ef957a428abbaa208241125819 ["pipeline"]
node3["add1"]
node4["[lambda]"]
end
node3 --> node4
click node3 console.log "def add1(value):<br/>    return value + 1<br/>"
click node4 console.log "lambda ...: ..."
pipeline_98e33e0628b546268abb2af5f74e50f1 --> pipeline_205813c806fd4b37b40309497768f7c1
pipeline_205813c806fd4b37b40309497768f7c1 --> pipeline_d2f205ef957a428abbaa208241125819
项目详情
下载文件
下载适合您平台的应用程序。如果您不确定要选择哪个,请了解有关 安装包 的更多信息。
源代码分发
此版本没有可用的源代码分发文件。请参阅 生成分发存档的教程。
构建分发
picopipe-1.0.2-py3-none-any.whl (8.1 kB 查看哈希值)