mapreduce wordcount在使用Octo-modu中的示例

Question

我刚开始学习mapreduce与Octo模块和单词计数的例子。我试着数数dir hw3data中的单词（如下所述）。我的电脑既是服务器又是客户端。在

我从两个终端的windows命令开始

服务器：十月.py服务器字数.py 服务器端似乎没有问题

客户：十月.py客户端本地主机 python似乎找不到我存储在hw3data dir中的txt文件，所以它说no work，sleep。有人能帮忙吗？在

在字数.py代码在下面

在字数.py

服务器

import glob

text_files=glob.glob('C:/Python27/octopy-0.1/hw3data/*.txt')

def file_contents(file_name):
    f=open(file_name)
    try:
        return f.read()
    finally:
        f.close()

source=dict((file_name,file_contents(file_name)) for file_name in text_files)

f=open('outfile','w')
def final(key,value):
    print key,value
    f.write(str((key,value)))

客户

^{pr2}$

Answer 1

更改以下代码

text_files=glob.glob('C:/Python27/octopy-0.1/hw3data/*.txt')

到

^{pr2}$

试试看。我想文件夹里的文件没有扩展名。在

Answer 2

验证您的数据文件在他的名字中是否有“.txt”。我正在把这道题改成作业3。祝你好运！在