У меня есть файл потока, содержащий пары значений ключа, я буду читать из Kafka и отправлять в Nifi, используя Getfile. Я получу файл, а затем, используя Configure Process, мы можем извлечь содержимое потока файлов и сохранить их как атрибуты потока файлов, добавив соответствующие регулярное выражение.
Теперь после этого мне нужно использовать атрибут (ы) speci c (который я получил на предыдущем шаге) и его значение (я) и сравнить с конкретным строковым значением или прочесть соответствующее свойство. значение из файла nifi.properties или файла пользовательских свойств.
Теперь, исходя из действительности, мне нужно выполнить скрипт с помощью команды ExecuteStream, предположим, что извлеченное значение атрибута и nifi.properties или значения пользовательских свойств совпадают, тогда я должен выполнить сценарий. Здесь запрос состоит в том, как сравнить значения свойств и выполнить скрипт.