骡子快跑支持四类熔断配置:一、启用runtime层内置熔断开关;二、为指定http依赖配置独立熔断策略;三、在超级智能体模式中声明式启用降级逻辑;四、通过api请求头动态触发熔断状态。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜

如果您在使用骡子快跑执行高并发任务或调用外部依赖服务时遭遇响应延迟激增、失败率陡升,导致整体任务链路不可靠,则可能是缺乏对异常传播的主动拦截能力。以下是配置熔断机制的具体操作路径:
一、启用Runtime层内置熔断开关
骡子快跑的Runtime层已集成轻量级熔断控制器,可在检测到下游服务连续失败时自动切断请求流,避免雪崩效应。该机制默认关闭,需显式激活并设定阈值。
1、打开骡子快跑配置文件/etc/mulerun/config.yaml。
2、在runtime:节下新增字段:circuit_breaker_enabled: true。
3、添加熔断参数块:failure_threshold: 5(10秒内失败5次即触发)、sleep_window_ms: 60000(休眠窗口60秒)、request_volume_threshold: 20(最小请求数门槛)。
4、保存后执行systemctl restart mulerun-agent使配置生效。
二、为指定HTTP依赖配置独立熔断策略
当任务链路中存在多个异构服务(如同时调用天气API与支付网关),需为关键性较低的服务单独设置宽松熔断参数,防止其故障拖垮主流程。此方式通过域名粒度隔离控制面。
1、在config.yaml的network:节内,添加circuit_breakers:映射表。
2、为每个目标域名定义策略,例如:api.weather.com: {failure_threshold: 8, sleep_window_ms: 30000}。
3、确保该域名未被concurrent_requests_per_domain限流规则覆盖,否则熔断判定将失效。
4、重启服务后,可通过curl -X GET http://localhost:8080/metrics | grep circuit验证指标上报是否正常。
三、在超级智能体模式中声明式启用降级逻辑
该方法适用于自然语言驱动的任务编排场景,无需修改配置文件,而是通过语义指令绑定fallback行为,系统自动注入熔断上下文。
1、进入超级智能体模式,在输入框中输入:“调用订单查询接口时,若超时或返回错误码503,自动切换至本地缓存数据并标注‘缓存’字样”。
2、等待AI确认语义解析结果,点击对话末尾出现的“绑定降级策略”标签。
3、系统将生成唯一策略ID,并写入当前Agent的fallback_rules记忆节点。
4、后续执行中,当检测到匹配的HTTP状态码或超时事件,立即执行缓存读取动作,不等待重试。
四、通过API请求头动态触发熔断状态
开发者可在单次HTTP API调用中临时覆盖全局熔断配置,实现灰度发布或压力测试期间的精准干预,该设置仅对本次请求生效。
1、向骡子快跑任务运行端点(如https://api.mulerun.com/v1/tasks/run)发送POST请求。
2、在请求头中添加:X-MuleRun-CB-Override: {"enabled":true,"failure_threshold":3}。
3、确保请求体JSON中包含"fallback_behavior": "return_empty"字段以明确降级动作。
4、服务端接收到该头后,跳过配置文件读取,直接加载头中定义的熔断参数并初始化控制器实例。











