Nifi: Ошибка выполнения скрипта (невозможно создать строку с небайтовым значением)

Question

Я пытаюсь проанализировать файл потока с помощью процессора executeScript.По сути, я делаю содержимое потокового файла с помощью скрипта Python и создаю из него csv.Это хорошо для моих образцов данных.Но каждое прод-сообщение имеет длину около 10000 символов.

Чтобы разделить это и преобразовать файл потока в csv, код python стал большим.Запуск этого получил меня error1.Я попытался преобразовать это в PyC-файл, а затем я получил error2.

Пожалуйста, дайте мне знать, что я могу сделать, чтобы решить эту проблему.

Answer 1

Для развертывания скриптов на Nifi я обычно использую этот проект: https://github.com/mattyb149/nifi-script-tester

Вы можете поместить файлы python в ресурс, например: https://github.com/mattyb149/nifi-script-tester/blob/master/src/test/resources/test_json2json.py

и протестировать его,