У меня проблемы с потоком данных с использованием Nifi, конечно, потому что я не понимал, как работает Wit / Notify. Вот мой основной поток данных:
- Я перечислил свое ведро s3, содержащее zip-файлы.
- Извлек мой файл Json из почтового индекса. Каждый Json от 2 Гб до 3 Гб.
- Затем я несколько раз разделил свой JSON, чтобы избежать «Недостаточно памяти», чтобы получить синг-записи FlowFiles (вот и проблема).
- Я хочу сгладить каждый файл
- Я хочу объединить мой плоский FF, чтобы получить оригинальный Json. Я знаю, что не могу сделать с "Слияние контента".
Не могли бы вы объяснить, как использовать Ожидание / Уведомление? Потому что я не поняла. Я также посмотрел на этот пост , но до сих пор не ясно.
Спасибо