Apache Nifi Как создать список значений, разделенных запятыми, из содержимого потокового файла

Question

Используя Apache Nifi Я хочу создать пакетный список значений, извлекая значение первичного ключа из содержимого потокового файла.

1. GETHDFS
2. SPLITCONTENT
3. ROUTEONATTRIBUTE (просто отфильтровывает файлы размером менее 1,01 байта из-за проблемы с кодом, не обращайте внимания на этот шаг)
4. EVALUATEJSONPATH, который производит контент: {"hist_idn": 12345678, "filename": "Retry_Spark_HIST_IDN_12345678_I", "reprocess_status": "N", "reprocess_date": "2019-07-19 10:19:18"}
5. Отсюда мне нужна помощь, моя цель - создать список разделенных запятыми каналов hist_idn это в выполнить sql с помощью команды: select * from History_table, где hist_idn in (список, сгенерированный nifi, разделенный запятыми)

Любая помощь будет принята с благодарностью.

Answer 1

@ chris fowler Следующим шагом, который вам нужно, является оценка JsonPath по сравнению с содержимым из # 4. Или настройте # 4, чтобы получить $ .hist_idn напрямую, предполагая, что это дочерний элемент более крупного родительского объекта json. После того, как hist_idn является атрибутом, вы можете работать в нисходящем направлении для объединения. Если вы получаете несколько строк в # 4, я предлагаю использовать программу чтения записей для запроса json всех значений hist_idn, которые вы хотите отправить вниз по потоку.