必须用批处理节点实现高吞吐个性化通知:配置arrayobject型开始节点→设50最大并行数→模板插值{{item.name}}和{{now}}→按联系方式分短信/邮件/日志分支→飞书或企业微信推送。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜

你需要在扣子平台中对上千名用户批量发送个性化通知,比如活动提醒、订单状态更新或系统公告,要求每条消息能带用户昵称、时间戳等动态字段,且不希望逐个调用API拖慢整体速度——这种高吞吐、强并发、需字段插值的场景,必须用批处理节点,不能用循环节点。
准备用户数据并配置开始节点
进入扣子开发平台(https://www.coze.cn/studio)→ 工作空间 → 资源库 → 点击「+资源」→ 选择「开始节点」。
参数名设为user_list,类型必须选【ArrayObject】,示例值填:[{"id":"u1001","name":"张三","phone":"138****1234"},{"id":"u1002","name":"李四","email":"lisi@example.com"}]。若误选ArrayString,后续批处理将无法提取name、email等嵌套字段,整个流程会在第一轮就报KeyError。
数组长度建议先用10条测试,确认流程通后再扩到千级;字段名必须全小写、无空格、不含中文,否则下游模板渲染会失败。
添加并配置批处理节点
从左侧节点库拖入「批处理」节点,连接开始节点的输出端口到其输入端口。
双击批处理节点,在「输入数组」字段中填入{{start.user_list}}——这个路径必须从右侧变量面板点选,手敲极易漏掉大括号或拼错start。
在「最大并行数」中填50。这是关键平衡点:【超过80可能触发平台限流,低于20则千级任务耗时翻倍】。实测50是免费版账户在稳定性和速度间的最优值。
勾选「启用错误跳过」。当某条用户数据缺失phone字段导致短信插件失败时,该条自动跳过,其余999条继续执行,避免整批中断。
在批处理体内组装并发送通知
第一步:拖入「模板」节点,放在批处理体内部。模板内容写:【尊敬的{{item.name}},您有新订单待处理,时间:{{now}}。】
注意:{{now}}是扣子内置时间变量,无需额外设置;但{{item.name}}必须与开始节点里ArrayObject的字段名完全一致,大小写敏感。
第二步:接一个「条件分支」节点,判断用户联系方式类型。当{{item.phone}}存在且非空时,走「短信插件」分支;当{{item.email}}存在时,走「邮件插件」分支;两者都为空则走「日志记录」分支写入失败原因。
第三步:每个分支末端都接「结束节点」。不要在批处理体内放「设置变量」累积结果——批处理节点不支持中间变量跨轮次传递,这是它和循环节点的本质区别。
绑定推送通道并发布
方法一:用飞书机器人推送(推荐用于内部通知)
在短信/邮件插件后接「飞书消息推送」节点,Webhook地址从飞书管理后台复制粘贴,消息体选「富文本」,内容填{{template.output}}。
方法二:用企业微信API推送(适合客户触达)
需提前在企业微信管理后台开通「应用」并获取AgentId、Secret;在「代码」节点中调用get_access_token接口,再用该token调用send_msg接口。这一步必须用代码节点,因为企业微信签名逻辑无法用纯配置实现。
最后点击「发布」按钮。发布前务必点击右上角「试运行」,传入3条测试数据观察日志——若看到“batch completed: 3/3”,说明千级任务已可安全启动。











