Мне поручено преобразовать нашу конфигурацию logstash в NiFi. Глядя на нашу конфигурацию logstash, есть фильтр kv, который принимает ваше сообщение и разбивает пары ключ-значение на новые атрибуты. Я хочу сделать то же самое в NiFi, но не уверен, что лучший способ сделать это в nifi. Может ли NiFi это сделать?
Пример 1
Вход
узел = 93266aa тип = OPTTYPE systemcall = 44 success = yes exit = 40 a0= 6 a1 = 7f31a21a77e0 a2 = 28 a3 = 0 элементов = 0 ppid = 9521 pid = 2547
Выход
{"узел": "93266aa", "тип":" OPTTYPE "," systemcall ":" 44 "," success ":" yes "," exit ":" 40 "," a0 ":" 6 "," a1 ":" 7f31a21a77e0 "," a2 ":«28», «a3»: «0», «items»: «0», «ppid»: «9521», «pid»: «2547»}
По сути, просто набор ключей, которыеслева от знака равенства, а значение справа, все разделены пробелом. ПОЖАЛУЙСТА, ОБРАТИТЕ ВНИМАНИЕ, я не знаю, что это за ключи. У меня не будет таких же ключей (таких как узел, тип, системный вызов и т. Д.), Как у меня в приведенном выше примере, это зависит от данных. Может ли NiFi быть таким динамичным?