基本的には mapreduce を実行しているので、reducer にパイプします。私が問題を抱えているのは、基本的に os.listdir で使用するディレクトリパスを指定して、そのディレクトリ内のすべてのファイルを単独で計算する方法です。しかし、同じレベルのサブディレクトリではなく、最後のディレクトリにあるものだけが必要であることはわかっています。fileinput() の使用も検討する場合があります。
ここで stdin を間違って使用している可能性があると思いますが、コマンド ラインから使用する必要があるか、コマンド ラインから間接的に使用できるかによって異なります。
これは私のコマンドライン入力でした: "./path1/path2/path3" ./map.py | ソート | ./red.py
私がやりたいことを実行してエラーとして得たのは、ディレクトリ ./pythonfile.py ではなく -bash です
Python 2.7.2 の使用
これは私がやっていることです:
def func():
path = sys.argv[0]
return [filenames for filenames in os.listdir(path)if os.path.isfile(os.path.join(path,filenames))]
if func() is not None:
for file in func():
sys.stdin.read()
...etc..