# 预处理消息路由模块 以python语言编写 ## 流水线结构 ### 接收redis-cli消息,根据DAG yaml文件分发 - .tasks.task[n]不含upstream_tasks的模块为第一个接收消息的模块 - 检索.tasks.task[n]中upstream_tasks,检索模块间链接关系,将消息下发给下级模块 ### qc0 ### mbi ### mbi-photmix