微信机器人处理简单指令够了——用户说查物流查一条回一条。处理复杂需求就不行——帮我把昨天的订单都核对一遍有问题的标出来然后生成报告发给我背后是查订单、逐单核对、标记问题、生成报告、发送用户多个子任务。复杂需求不是字数多的需求是不能一步完成、需要拆成子任务按依赖关系执行的需求。智能任务拆解要解决三个问题要不要拆、拆多细、按什么顺序执行。一、复杂度识别——先判断要不要拆不是所有请求都需要拆解。用户说查物流直接查不需要拆。复杂度识别是任务拆解的第一道关卡——判断是简单指令还是复杂需求简单的直接执行复杂的才进入拆解流程。判断维度有三个是否涉及多个对象一个订单 vs 全部订单、是否需要多步骤查核对标记报告、是否有依赖关系标记依赖核对结果。复杂度识别的价值是避免过度拆解。简单请求强行拆成子任务拆解开销超过执行开销——查物流拆成解析单号查询组装三个子任务除了增加调度没有意义。复杂度阈值要可配置按业务场景调。消息解析和复杂度判断的接口在 Eyun 开发文档 中有对应支撑。二、拆解粒度控制——拆多细是个工程选择确认要拆后拆多细是关键选择。拆太粗——核对全部订单拆成一个子任务执行时还是什么都干等于没拆。拆太细——核对全部订单拆成取列表取每个详情核对每个收集结果10个订单拆出40个子任务调度开销爆炸。合理的粒度是按业务动作拆——一个不可再分的业务动作是一个子任务核对单个订单是一个子任务10个订单是10个子任务实例。粒度控制的原则是业务动作不可再分。查昨日订单是一个动作核对单个订单是一个动作生成报告是一个动作。按业务动作拆而非按技术步骤拆能保证子任务数量与业务规模成正比不会因输入量大而拆解层数暴增。拆解粒度的控制策略和任务调度的接口在 Eyun 开发文档 中有对应能力。三、子任务依赖排序——执行顺序由依赖关系决定子任务拆出来后执行顺序不是按拆解顺序而是按依赖关系。核对订单依赖查询结果生成报告依赖核对结果发送报告依赖报告生成完成。依赖排序的价值是保证子任务在依赖项完成后才执行——没查到订单就开始核对核对的是空数据。依赖排序的实现是DAG有向无环图——子任务是节点依赖关系是边拓扑排序后按序执行。DAG中无依赖关系的子任务可以并行——10个订单的核对子任务互不依赖可以并行执行。依赖排序要注意环检测——循环依赖会导致执行死锁拆解时就要检测并报错。子任务执行和结果汇总的接口在 Eyun 开发文档 中有接口能力。任务拆解三环节对照环节判断维度控制原则输出复杂度识别对象数步骤数依赖阈值可配置拆/不拆拆解粒度业务动作不可再分按动作非按步骤子任务列表依赖排序子任务间依赖关系DAG拓扑排序执行顺序任务拆解与依赖排序实现class TaskDecomposer: COMPLEXITY_THRESH {multi_obj: 3, multi_step: 2} def decompose(self, request): if not self.is_complex(request): # 复杂度识别 return [request] # 简单指令不拆 subtasks self.split_by_action(request) # 按业务动作拆 return self.topo_sort(subtasks) # DAG依赖排序 def is_complex(self, request): # 判断对象数步骤数同时超阈值 return (request.object_count() self.COMPLEXITY_THRESH[multi_obj] and request.action_count() self.COMPLEXITY_THRESH[multi_step]) def split_by_action(self, request): actions self.extract_actions(request) tasks [] for act in actions: if act.type check_batch: # 批量动作按对象拆成子实例 tasks.extend(self.expand_batch(act)) else: tasks.append(Task(act)) return tasks def topo_sort(self, tasks): graph self.build_graph(tasks) # 建DAG if self.has_cycle(graph): # 环检测 raise DecomposeError(循环依赖) return graph.topo_order()落地建议复杂度识别阈值别拍脑袋定——先观察真实用户请求统计简单和复杂的分布再定阈值。拆解粒度按业务动作拆而非按技术步骤拆保证子任务数量与业务规模成正比。依赖排序必须做环检测——循环依赖导致执行死锁拆解时检测比运行时报错好排查。微信侧的消息解析、子任务执行和结果汇总由Eyun这类个人微信API平台 提供复杂度识别和依赖排序在自建服务实现接口字段以平台开发文档为准。
