Дело не в том, что NiFi не поддерживает собственные модули Python как таковые, скорее это движок Jython, который мы используем в NiFi (поскольку NiFi - это чистая реализация Java), который не поддерживает его.Если у вас есть интерпретатор Python на узле (ах), на котором работает NiFi, вы можете использовать ExecuteStreamCommand
для оболочки на Python, используя ваш скрипт (с собственным импортом), вы получите содержимое файла потока как stdin
ивы бы написали свою логику шифрования / дешифрования для вывода в stdout
, который стал бы содержимым файла исходящего потока.
Я смотрю на процессор Py4J, чтобы мы могли обойти ограничение Jython для nativeмодули, но вам все равно придется принести свой собственный Python (BYOP).На данный момент, если вы не хотите делать что-то более сложное, чем получение содержимого потокового файла и запись содержимого потокового файла, ExecuteStreamCommand должен выполнить свою задачу.