文件名称：ank:Python数据管道
文件大小：39KB
文件格式：ZIP
更新时间：2024-05-23 07:57:32
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)