Wie Logstash nil Wert richtig mit Plain Formater behandeln

Question

Ich benutze Logstash Lesen von Daten von MySQL zu Kafka. für den Speicherplatz zu sparen, ich schreibe Ausgabe Config wie folgt aus:

kafka { 
    codec => plain { 
     format => "%{key1},%{key2},%{key3}" 
    } 
} 

wie ich erwarte, dass durch eine solche Eingabedaten geben:

{ 
    key1: value1, 
    key2: nil, 
    key3: value3 
} 

Die Ausgabe sollte wie folgt aus:

value1,,value3 

aber die tatsächliche Ausgabe ist dies:

value1,%{key2},value3 

Wie man Ausgangskonfiguration setzt, um die Null mit "" zu konvertieren, weiß jeder?

Bogen

Answer 1

In Ihrem Filter hinzufügen:

if [key2] { } else { 
    mutate { 
     remove_field => ["key2"] 
    } 
    mutate { 
     add_field => ["key2", ""] 
    } 
} 

Wenn das Feld key2 oder null fehlt, wird es mit einem leeren String als Wert ersetzt werden.