Notes of benthos

summary

Record some corners that may be used at ordinary times

Error handling

If you use kafka Wait for some of your own input, When a process returns error When , Will automatically retry , This is annoying , It can be used fallback solve .
as follows

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

If an error is reported during output, it will automatically jump to the next output .