Dify 中级实验04迭代进阶——如何批量处理数据并守住性能边界Dify 实验系列 · 中级 04/20 | 实验编号DIFY-102-05上篇Dify 中级实验03模板转换实战——如何用零 Token 完成文本加工1. 实验目的掌握Iteration迭代节点的高阶用法嵌套迭代、逐条质量过滤、条件分流、输出结构设计以及性能边界——迭代不是无限的30 个元素上限、10 分钟超时、并行数限制都是真实约束。适合场景批量取数、逐条审核、分页采集、批处理流水线——任何「拿到一个数组逐条处理」的需求。2. 场景设计从多个数据源拉取客户反馈每个源返回多条评论需要外层迭代遍历数据源列表3 个源内层迭代对每个源的评论逐条做质量过滤内容过短、纯标点、重复字符判为低质只有质量合格的评论才送 LLM 做情感分析最终汇总「扫描总数 / 有效数 / 拦截数」。输入sourcesJSON 数组每项含 name/url/limit[{name:App Store,url:https://api.example.com/reviews/app,limit:3},{name:Google Play,url:https://api.example.com/reviews/android,limit:2},{name:官方论坛,url:https://api.example.com/reviews/forum,limit:4}]输出总扫描 9 条、有效分析 N 条、被拦截 M 条 各源明细。3. 节点拓扑开始sourcesJSON ↓ 解析数据源配置Codejson.loads 截断 [:20] ↓ 外层迭代遍历数据源iter_sources ├─ 模拟获取数据源评论Code按 limit 生成 mock 0.2s 延迟 │ ↓ │ 内层迭代逐条质量过滤与分析iter_reviews │ ├─ 质量过滤Codequality_ok 判定 │ │ ↓ │ │ 质量合格判断IF-ELSE │ │ ├─ case_ok → 情感分析LLM→ 汇聚分析结果Code │ │ └─ case_bad → 汇聚分析结果Code ↓ 汇总统计Code→ 结束4. 关键配置4.1 开始节点变量variables:-label:数据源配置JSON 数组每项含 name/url/limitrequired:truetype:paragraph# 长 JSON 粘贴paragraph 而非 text-inputvariable:sources4.2 外层迭代容器迭代输入数组有30 个元素上限解析节点先截断留余量defmain(sources_text:str)-dict:importjsontry:datajson.loads(sources_textor[])ifnotisinstance(data,list):data[]exceptException:data[]datadata[:20]# 迭代上限 30提前截断return{source_items:data,total:len(data)}外层迭代容器配置节选-data:error_handle_mode:terminatedis_parallel:falseiterator_selector:[cd_parse,source_items]output_selector:[iter_reviews,output]# 内层迭代的输出output_type:array[string]parallel_nums:10start_node_id:itstart0title:外层迭代遍历数据源type:iterationid:iter_sources4.3 质量过滤Code低质判定逻辑输出quality_ok——注意布尔值展平为字符串变量选择器看不到 boolean 类型下游 if-else 也只用字符串比较defmain(review:dict)-dict:importre reviewreviewor{}contentstr(review.get(content,)or)quality_issues[]iflen(content)3:quality_issues.append(内容过短)ifre.match(r^[!.。?,。]$,content):quality_issues.append(无实质内容)iflen(set(content))2andlen(content)1:quality_issues.append(疑似垃圾评论)return{quality_ok:trueiflen(quality_issues)0elsefalse,# 字符串不是布尔quality_issues:quality_issues,...}4.4 内层分支与 LLMIF-ELSE 用is比较字符串不能用cases:-case_id:case_okconditions:-comparison_operator:isvalue:truevariable_selector:[cd_quality,quality_ok]logical_operator:and-case_id:case_badconditions:-comparison_operator:isvalue:falsevariable_selector:[cd_quality,quality_ok]logical_operator:and迭代内 LLM 引用当前元素用{{#iter_reviews.item.字段#}}且必须显式reasoning_format: separated——否则思考过程混入 text整个迭代输出数组都被污染prompt_template:-id:p_analyzerole:systemtext:|分析以下用户评价 平台{{#iter_reviews.item.platform#}} 用户{{#iter_reviews.item.user#}} 评分{{#iter_reviews.item.rating#}}/5 评价内容{{#iter_reviews.item.content#}} 输出分析结论50字以内 1. 情感倾向正面/中性/负面 2. 核心关注点 3. 可采取的行动建议reasoning_format:separated5. 运行验证输入上方 sources 测试数据观察检查项预期实测外层迭代次数33 个数据源3内层迭代总次数93249质量过滤拦截低质评论被拦不走 LLM与预期一致汇总输出扫描 9 条 / 有效 N 条 / 拦截 M 条与预期一致进阶对比把外层迭代is_parallel打开并行数 3再跑一次对比串行/并行耗时——本实验 mock 延迟 0.2s数据量小看不出差距数据量大了差异明显。6. 采坑点坑现象修复迭代输入数组超 30 个运行报then length of var item must be less than 30 elements上游代码节点data[:20]提前截断留余量output_selector 选 array[object]迭代输出为空数组下游取不到内部代码节点json.dumps序列化为 stringoutput_type: array[string]布尔输出给下游判断变量选择器看不到 boolean取不到值输出true/false字符串if-else 用is比较嵌套迭代内部节点 parentId 写错层级校验报「parentIdNone 不是 iteration 节点」parentId 是节点外层字段与 id 同级不是 data 内迭代内 LLM 缺 reasoning_format思考过程混入 text判断逻辑全乱显式reasoning_format: separated 嵌套迭代格式本身能通过校验但 Dify 运行层对「迭代套迭代」支持有限——如果你的场景不需要逐源再逐条的两级结构优先用「串联迭代 展平代码节点」更稳。7. 实验文档及源码获取实验文档完整操作步骤DIFY-05迭代进阶——批量处理的边界与陷阱.md源码可直接导入dify102_05_批量反馈分析器.yml文章聚焦核心配置与采坑点实验的完整分步操作节点搭建/参数表/调试指引见实验文档原文。下一篇Dify 中级实验05并行执行——如何让多路任务同时跑
)
