Comment logstash gérer correctement la valeur nulle avec formater plaine

Question

J'utilise les données de lecture logstash de mysql à kafka. pour économiser l'espace disque, j'écris config de sortie comme ceci:

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

comme je l'espère, en leur donnant des données d'entrée:

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

la sortie devrait comme ceci:

value1,,value3 

mais la sortie acutal est la suivante:

value1,%{key2},value3 

comment configurer la configuration de sortie pour convertir le zéro avec "", quelqu'un sait?

arc

Answer 1

Dans votre filtre, ajouter:

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

Si le champ key2 est manquant ou nul, il sera remplacé par une chaîne vide comme valeur.