фильтровать данные json по nifi по маршруту по атрибуту

Question

У меня есть источник, который производит данные json, и каждый файл содержит только одну запись, как показано ниже file1: -

{"X":"12","Y":"23","r":"3","V":"0"}

file2: -

{"r":"32","Y":"24","x":"3","V":"12"}

file3: -

 {"v":"1","r":"23","x":"3","y":"23"}

теперь в nifi я хочу отфильтровать все файлы, если y = 23 и v = 0 для одного пункта назначения и для остальных пунктов назначения.может ли кто-нибудь помочь мне

мой поток nifi: -

мой маршрут на процессоре атрибутов

Может ли кто-нибудь помочь мне написать условие, чтобы я мог фильтровать данные в соответствии с вышеуказанными требованиями

Answer 1

Извлеките значения для y,v в EvaluateJSONPath процессоре и добавьте новое выражение в RouteOnAttribute процессоре для фильтрации требуемых потоковых файлов.

Попробуйте использовать приведенное ниже выражение, используя Язык выражений NiFi :

${y:equals('23'):and(${v:equals('0')})}