filter {
mutate {
add_field => {
"message" => "%{global_stats},%{num_rows}"
}
remove_field => ["oldfield1", "oldfield"]
}
grok {
add_tag => [ "valid" ]
match => [ "message" , "^YES,[123456789]+$"]
#}
grok {
add_field => {
"message" => "%{global_stats},%{num_rows}"
#}
match => [ "message" , "^YES,[123456789]+$" ]
tag_on_failure => ["failed records"]
add_tag => ["parsed"]
}
#grok {
match => [ "num_rows", "^[123456789]+$" ]
tag_on_failure => ["failed records"]
#}
}