Dify 中级实验(16):错误处理与降级——工作流如何有尊严地失败?
Dify 实验系列 · 中级 16/20 | 实验编号:DIFY-102-17
1. 实验目的
掌握生产级 Workflow 的错误处理设计:节点级异常捕获、状态码分级降级、日志与告警、超时与重试。核心观点一句话——错误不是「如果发生」,而是「什么时候发生」;没有错误处理的应用,一个异常就能让整条链路崩溃,而我们要做的是让它有尊严地失败:降级优于报错,报错也要留痕。
2. 场景设计
应用上线后常见的「想不到」:外部 API 返回 500、模型超时限流、代码节点抛异常。本实验搭一个「容错架构演练」工作流,用httpbin.org 可控状态码端点模拟外部 API:
- 输入:
input_data(任意文本,作为请求内容) - 主链路:HTTP 请求
https://httpbin.org/status/500→ 按状态码分流(500 降级 / 200 正常)→ 统一日志判定 → 严重级别判断 → 告警或正常收尾
重点观察:同一个 HTTP 节点如何把「业务失败(500)」和「网络失败(超时/断连)」分开处理。
3. 节点拓扑
开始(input_data) ↓ 请求API(HTTP:httpbin.org/status/500,超时 5s,重试 2 次,error_strategy=fail-branch) ↓ 状态码判断(IF-ELSE) ├── case_500(status_code = 500)→ 降级处理(Code)→ 日志判定(Code)→ … └── case_200(status_code = 200)→ 正常处理(Code)→ 日志判定(Code)→ … ↓ 严重级别判断(IF-ELSE) ├── case_critical → 告警模拟(Code)→ 告警说明(LLM)→ 结束 └── case_warning / case_info → 正常说明(LLM)→ 结束12 个节点、13 条边。关键设计:降级路径和正常路径在「日志判定」节点汇合——无论哪条路,错误都要被记录、分级、决定是否告警。
4. 关键配置
4.1 HTTP 节点(核心)
type:http-requesturl:"https://httpbin.org/status/500"method:"get"timeout:{connect:5,read:60,write:20,max_connect_timeout:300,max_read_timeout:600,max_write_timeout:600}retry_config:{max_retries:2,retry_enabled:true,retry_interval:1000}error_strategy:"fail-branch"authorization:{config:null,type:no-auth}ssl_verify:true要点:
- 超时 5 秒 + 重试 2 次(间隔 1s)——瞬时抖动自动扛过去
error_strategy: fail-branch让节点长出两个输出口:成功口source和失败口fail——500 属于「请求成功但业务失败」,走成功口再判断;fail口只管网络层失败(超时/断连/无响应体)
4.2 状态码判断(IF-ELSE)
数字比较必须写全varType: number+numberVarType: constant,值仍是字符串字面量:
cases:-case_id:case_500conditions:-comparison_operator:"="# 数字比较用 =,字符串比较才用 isnumberVarType:constantvalue:"500"variable_selector:[http_call,status_code]varType:numberlogical_operator:and-case_id:case_200conditions:-comparison_operator:"="numberVarType:constantvalue:"200"variable_selector:[http_call,status_code]varType:numberlogical_operator:and4.3 日志判定节点(Code)
两条路径在此汇合,把错误转成可观测的结构化日志,并输出告警开关(boolean 展平成 string):
defmain(status_code:int,user_input:str,degrade_message:str,normal_message:str)->dict:importtimetry:code=int(status_codeor0)exceptException:code=0ifcode>=500:severity="critical"elifcode>=400:severity="warning"else:severity="info"message=degrade_messageornormal_messageor""log_id="ERR-{}".format(int(time.time()))return{"severity":severity,"log_message":message,"log_id":log_id,"need_alert":"true"ifseverity=="critical"else"false"}severity分级(critical/warning/info)直接驱动下游严重级别判断:critical 才触发告警,warning/info 只记日志正常收尾——不是所有错误都要惊动告警通道。
5. 运行验证
| 场景 | 操作 | 预期 | 实测结果 |
|---|---|---|---|
| 业务失败 | 保持httpbin.org/status/500 | 状态码 500 → 降级处理 → severity=critical → 告警输出 | 500 分支触发,告警模拟节点执行 ✓ |
| 正常响应 | 把 URL 改为httpbin.org/status/200 | 状态码 200 → 正常处理 → severity=info → 正常说明 | 200 分支触发,正常收尾 ✓ |
| 超时降级 | 改为不可达域名(如httpbin.org:81) | 网络层失败走 fail 口 | 需在完整版中把 fail 口接降级节点(见采坑点) |
运行日志里核对:HTTP 节点耗时、状态码值、log_id时间戳、最终输出内容。
6. 采坑点
| 坑 | 现象 | 修复 |
|---|---|---|
| httpbin.org 外网不稳定 | 演示时偶发超时/连接失败,工作流卡住或直接失败 | 教学演示可临时改用本地 mock(代码节点模拟响应);生产环境把 fail 口接到降级分支 |
| fail-branch 的 fail 口没接线 | 网络层失败(超时/断连)时没有出路,整条链路失败 | 完整版把fail口接「网络降级」节点;记住 fail 口只管网络层,4xx/5xx 状态码走成功口 |
| 把 500 判断接到 fail 口 | 500 有响应体但 fail 口不触发,降级逻辑永远不执行 | 500 走成功口 + if-else 判断status_code;fail 口只接超时/断连类降级 |
数字比较漏写varType | 状态码判断不生效或校验报错 | 数字条件补varType: number+numberVarType: constant,运算符用=/≥/≤(Unicode) |
need_alert用 boolean 输出 | 下游 IF-ELSE 判断不到(类型不可见) | 展平为 string"true"/"false" |
采坑点来自本实验 DSL 生成与运行验证的真实记录(fail-branch 双口语义、httpbin 外网依赖、数字比较格式)。
7. 实验文档及源码获取
- 实验文档(完整操作步骤):DIFY-17:错误处理与降级架构.md
- 源码(可直接导入):dify102_17_容错架构演练.yml
- DSL 目录:dify-102/dsl/
文章聚焦核心配置与采坑点;实验文档还包含降级回路(简化提示重试→静态回复)、迭代超时控制、HTTP 超时链、熔断模式、渐进式降级(L1-L4)等完整设计。
下一篇:Dify 中级实验(17):调试监控与性能优化——响应慢和 Token 超支如何定位?