添加故障处理器

添加故障处理器 #

通过故障处理器,可以在某个处理器执行失败时触发补充处理逻辑。

操作步骤 #

  1. 进入管道编辑页面:在「管道管理」页面找到目标管道,点击「操作」列的更多按钮(...),选择「编辑」进入管道编辑页面。

  2. 选择添加故障处理器:在目标处理器右侧点击更多按钮(...),在弹出菜单中选择「添加故障处理器」。

  1. 配置故障处理器
    • 选择「处理器类型」(如示例中的 Bytes)。
    • 根据处理器类型填写必填配置项。示例中填写「字段名」为 test_bytes
    • 按需配置「目标字段」「忽略缺失」「条件」「忽略出错」「标签」「描述」等高级选项。
    • 配置完成后,点击「确认」按钮。

  1. 保存管道:故障处理器添加成功后,将展示在目标处理器下方。确认配置无误后,点击「保存」按钮。

  1. 查看配置结果:保存成功后,可进入管道详情页查看处理器 JSON。示例中 Append 处理器下已包含 on_failure 配置,并在其中添加了 Bytes 故障处理器。

注意事项 #

  • 故障处理器只在其所属处理器执行失败时触发,适合用于错误兜底、字段补充或异常标记等场景。
  • 如果处理器开启了「忽略出错」,错误会被跳过,故障处理器可能不会按预期触发。
  • 保存前请确认故障处理器所属位置,避免将错误处理逻辑添加到错误的处理器节点下。