Nifi UpdateAttribute не работает для динамической переменной - PullRequest
Новая
       61

Nifi UpdateAttribute не работает для динамической переменной

0 голосов
/ 10 сентября 2018

Я пытаюсь получить количество файлов, обработанных ListHDFS, поэтому поток выглядит так:

ListHDFS -> UpdateAttribute -> LogAttribute

Я настроил UpdateAttribute согласно документации (см. Вложение). Странно, я даже не вижу «fileCount» в опции «Просмотр данных о происхождении».

enter image description here

Чего мне не хватает?

1 Ответ

0 голосов
/ 10 сентября 2018

Я могу видеть значение атрибута fileCount как 1 в происхождении данных,

Я воссоздал ваш сценарий как 

Generateflowfile --> UpdateAttribute --> LogAttribute

UpdateAttribute config:

fileCount ${getStateValue("fileCount"):plus(1)}

Переменные с изменяемым состоянием Начальное значение 0

Происхождение для файла: enter image description here

Начальное значение для атрибута fileCount равно null (без значения) и UpdateAttribute мы добавляем единицу к атрибуту fileCount , а новое значение равно 1 .

...