Результаты промывки PutSFTP? - PullRequest
Новая
       16

Результаты промывки PutSFTP?

0 голосов
/ 07 ноября 2018

Я хотел бы сохранить результаты в SFTP, эти результаты генерируются из большого дампа SQL между диапазонами дат. Для того же, я запускаю его через цикл для списков дат.

Но проблема заключается во время итерации i++. Содержимое потокового файла продолжает расти из исходящего содержимого потокового файла PutSFTP.

Как можно очистить результаты потокового файла PutSFTP процессора, чтобы его можно было избежать при следующей итерации? Однако в то же время я хотел бы сохранить другие важные переменные из разных UpdateAttribute в цикле.

Данный поток Нифи может быть показан следующим образом. enter image description here

1 Ответ

0 голосов
/ 07 ноября 2018

Использование ModifyBytes процессор, после PutSFTP процессор.

Configs:

enter image description here

С помощью этих конфигов мы собираемся удалить все содержимое существующего flowfile, и этот процессор не удалит никакие существующие атрибуты , связанные с потоковым файлом.

Расход: 

  -> other processors
 |(success)
  -> PutSFTP
 |(success)
  -> ModifyBytes
 |(success)
  -> i++(UpdateAttribute)
 |(success)
  -> other processors
...