【文件属性】：
文件名称：ank:Python数据管道
文件大小：39KB
文件格式：ZIP
更新时间：2021-05-03 14:10:52
docker distributed-systems microservices schedule queue
ANK-Python流系统
概述：
使用队列消息（rabbitMQ，zeroMQ，kafka）的Python Streaming系统，REST-API和Schedule任务每个处理器都是一个链，将其组合在一起就可以构成一条管道。
支持链模型：
1：1 processor - processor
1-n： / processor
processor - processor
\ processor
n-1： processor \
processor - processor
processor /
n-n： processor - processor processor - processor processor - processor
processor - processor processor / pr
【文件预览】：
ank-master
----MANIFEST.in(36B)
----CHANGES.md(333B)
----CONTRIBUTORS.txt(0B)
----ank()
--------utils()
--------generate_processor.py(4KB)
--------program_loader.py(3KB)
--------components()
--------__init__.py(701B)
--------cli.py(6KB)
--------daemon.py(6KB)
--------generate_setting.py(3KB)
--------tests()
--------templates()
--------chain_process.py(4KB)
----Dockerfile(372B)
----requirements.txt(85B)
----examples()
--------__init__.py(21B)
--------api_app()
--------streaming_app()
--------schedule_app()
----LICENSE(1KB)
----setup.py(1KB)
----README.md(5KB)
----TODO(257B)
----.gitignore(242B)