Importieren von Modulen in Nifi ExecuteScript

Question

Ich bin neu in Nifi und Python

Ich möchte mein Python-Skript ausführen. So benutzte ExecuteScript und versuchte bestimmte Module zu importieren. Ich habe wie folgt importiert:

import json, sftp, paramiko 

Obwohl ich SFTP installiert haben, wenn ich es in ExecuteScript importieren, heißt es „Sitzung verarbeiten fehlgeschlagen Kein Modul namens SFTP in Zeile Nummer 1“.

which -a sftp 
/usr/bin/sftp 

Beim Importieren von Paramiko wurde auch der gleiche Fehler angezeigt.

Answer 1

Der "Python" Motor verwendet von ExecuteScript und InvokeScriptedProcessor ist eigentlich Jython, nicht reiner Python. Das bedeutet, dass native Module (.so-Dateien, kompilierte C-Dateien usw.) nicht geladen werden können. Entsprechend , verwendet paramiko Crypto, das native Bibliotheken hat, also kann nicht in Jython verwendet werden (sehen Sie die Unterseite von this post für meinen Kommentar dazu). Meine Vermutung ist, dass die sftp-Bibliothek das gleiche tut.

Jython kann reine Python-Module verwenden, dort gibt es a discussion on the NiFi mailing list darüber, wie man auf diese Arten von Modulen zeigt (und sie einschließt).