benthos杂记

概述

记录一些平时可能会用到的边边角角

错误处理

如果使用kafka等一些自带的input，当中间有流程返回error的时候，会自动重试，这一点挺烦的，可以用fallback解决。
如下

output:
  fallback:
    - sql_raw:
        driver: mysql
        dsn: ${
    Alarm.Db.Dsn}
        query: "INSERT INTO cm_ala_corr_relation (rule_id, father_alarm_id, child_alarm_id, relation_time) VALUES (?, ?, ?, ?);"
        args_mapping: | root = [ this.RuleId, this.FatherAlarmId, this.ChildAlarmId, this.RelationTime ]
    - file:
        path: ./error_relation.txt

输出的时候报错的话自动跳到下一个输出。