oozieはPythonで独自のモジュールをインポートします

Question

私はOozieの初心者です。 main.pyでは、私自身のモジュールをインポートする必要がありますMY_CLASS.pyこれは、main.pyと同じHDFSパスにアップロードされています。

from MY_CLASS import my_class_1 

def main(): 
    x = my_class_1() 
    ... 

はImportErrorを言っoozie中にエラーが発生しました：MY_CLASSという名前のモジュールが。それはローカルでは完全に機能します。

また、HDFSにフォルダを作成しようとしましたが、フォルダがパッケージとして認識されるように、MY_CLASS.pyを__init__.pyと一緒に入れてください。しかし、from folder.MY_CLASS import *は私のためにうんざりしていません。

これを達成する方法を知っている人はいますか？どうもありがとう。

Answer 1

アンサーを見つけました。ちょうどexport PYTHONPATH=$(pwd)を追加する必要があります。