hub / github.com/MegEngine/MegFlow
github.com/MegEngine/MegFlow @v0.3.5
Chat with this repo
1,047 symbols
2,840 edges
207 files
61 documented · 6%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README
简体中文 | English
MegFlow Documentation
MegFlow 提供快速视觉应用落地流程，最快 15 分钟搭建起视频分析服务。其特性体现在：
- 直接用 Python 搭建计算图（如先检测、再跟踪、最后质量判断加识别），不必关心 C++、图优化相关问题
- 省去 SDK 集成、提升开发体验，通过流程改进应对人力不足、时间紧、功能多的情况
- 提供 pipeline 搭建、测试、调试、部署、结果可视化一条龙服务
HowTo
- 如何运行
- 使用预编译 .whl
- 生成 RTSP 地址
- 如何编译
- docker 编译
- ubuntu 源码编译
- win10 wsl 编译
-
构建自己的 pipeline
- tutorial01: quickstart 问答式创建应用
- tutorial02: detect and classify on video stream
- tutorial03: batching and pipeline test
- tutorial04: visualization
- how to debug
- how to contribute
- FAQ
Current Support Matrix
| 系统环境 | win10 docker/wsl2 | ubuntu | centOS | macos |
|---|---|---|---|---|
| x86 | ✔️ | ✔️ | ✔️ | ✔️ |
| ARMv8 | - | ✔️ | ✔️ | - |
| Python 版本 | 支持情况 |
|---|---|
| 3.6 | ✔️ |
| 3.7 | ✔️ |
| 3.8 | ✔️ |
| 3.9 | ✔️ |
Built-in Applications
Features
- 基于 async-std[features=tokio1] 的高效异步运行时调度器
- 简洁的基于 toml 的建图描述格式
- 支持静态、动态、共享子图
- 支持 Rust/Python 多语言共存（会 Python 即可）
- 支持资源管理（多层级跨任务共享）
- 支持异常处理（异常任务会终止所在静态图）
- 支持 demux/reorder/transform 等通用函数式组件
- Python 插件内置有栈协程，不依赖 asyncio
- 基础测试工具，支持插件沙盒，用于单测插件
- 基础调试工具，支持建图实时预览/qps profile
Coming Soon
- 进程级别的节点、子图支持
- 插件自动化测试部署
- 性能监控，inspect 等工具
- 更多内置应用和组件
Contact Us
- Issue: github.com/MegEngine/MegFlow/issues
- Email: megengine-support@megvii.com
- QQ Group: 1029741705
License
Extension points exported contracts — how you extend this code
Actor (Interface)Trait for interactiving with schedule, which can be derived by `#[derive(Actor)]`. [6 implementers]
flow-rs/src/node/mod.rs
IndexGet (Interface)
(no doc) [3 implementers]
flow-message/src/cross/mod.rs
Node (Interface)
Trait for interactiving with graph, which can be derived by `#[derive(Node)]`. [3 implementers]
flow-rs/src/node/mod.rs
IndexSetData (Interface)
(no doc) [3 implementers]
flow-message/src/cross/mod.rs
ChannelBase (Interface)
(no doc) [3 implementers]
flow-rs/src/channel/mod.rs
GetRef (Interface)
(no doc) [3 implementers]
flow-message/src/cross/data/mod.rs
AnyEnvelope (Interface)
(no doc) [2 implementers]
flow-rs/src/envelope/any_envelope.rs
GetMut (Interface)
(no doc) [3 implementers]
flow-message/src/cross/data/mod.rs
Core symbols most depended-on inside this repo
clonecalled by 109
flow-rs/src/channel/inner.rs
push
called by 102
flow-python/examples/application/cat_finder/visualize/visualize.py
as_ref
called by 86
flow-message/src/cross/map.rs
insert
called by 76
flow-rs/src/registry.rs
send
called by 60
flow-rs/src/channel/inner.rs
info
called by 53
flow-rs/src/graph/node.rs
append
called by 50
flow-rs/src/resource/storage.rs
get
called by 48
flow-rs/src/graph/node.rs
Shape
Languages
Rust71%
Python25%
TypeScript5%
Modules by API surface
flow-quickstart/src/git.rs28 symbols
flow-rs/src/channel/inner.rs26 symbols
flow-python/examples/application/warehouse/track_iou/track_iou.py23 symbols
flow-python/megflow/func_op.py21 symbols
flow-message/src/cross/data/mod.rs19 symbols
flow-rs/src/envelope/envelope.rs18 symbols
flow-rs/src/channel/storage.rs17 symbols
flow-python/examples/application/warehouse/reid_alignedreid/resnet.py17 symbols
flow-rs/src/registry.rs16 symbols
flow-rs/src/loader/python/envelope.rs16 symbols
flow-rs/src/loader/python/node.rs14 symbols
flow-quickstart/src/main.rs14 symbols
For agents
$ claude mcp add MegFlow \
-- python -m otcore.mcp_server <graph>