Пожалуйста, помогите!
Я читаю три типа файлов через ListFtp, например:
TRB_TIT_D190125.txt
TRB_SEG_D190125.txt
TRB_ASE_D190125.txt
Мне нужно обработать файл "TIT" в первую очередь. Мне нужно прочитать данные и вставить данные в таблицу. После завершения всех вставок я должен обработать файлы "SEG" и "ASE".
Я использую ожидание и уведомление, используя frag.count и frag.identifier, и это работает, но я не могу подключиться Ожидание к ListFTP, чтобы снова получить файлы SEG и POS, потому что ListFTP не разрешает входящие соединения, это всегда работает параллельно.
Я отложил второе ожидание, чтобы управлять потоком, который обрабатывает файлы "SEG" и "ASE", но у него нет возможности узнать фрагменты.count и фрагмент.идентификатор.
Я прилагаю изображение, которое объясняет проблему.
Заранее спасибо!
Nifi-flow.jpg
выжидательную configuration.jpg
извещать-configuration.jpg