基本上我正在运行mapreduce,所以我将通过管道进入reducer。我遇到的问题是如何指定一个目录路径,我将与 os.listdir 一起使用它来基本上访问然后单独计算该目录中的所有文件。但我知道我只想要最后一个目录中的内容,而不是同一级别的子目录。我也可以考虑使用 fileinput()。
我想我可能在这里使用了错误的标准输入,这取决于它是否必须来自命令行或者是否可以间接来自命令行。
这是我的命令行输入: "./path1/path2/path3" ./map.py | 排序 | ./red.py
做我想做的事情时我得到的错误是-bash,而不是目录./pythonfile.py
使用 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..