我试图用下面提到的代码通过Python脚本向HDFS写入一个文件。在
import hadoopy
import os
hdfs_path = 'data.json'
def read_local_dir(local_path):
for fn in os.listdir(local_path):
path = os.path.join(local_path, fn)
if os.path.isfile(path):
yield path, open(path).read()
def main():
local_path = '.'
hadoopy.writetb(hdfs_path, read_local_dir(local_path))
if __name__ == '__main__':
main()
在本例中,为了执行上述代码,我试图在cmd中pip install hadoopy
包,但安装失败。还尝试通过下载hadoopy-0.5.0进行安装。广州塔没用。请帮我解决这个问题。在
错误:
^{pr2}$提前谢谢。。!在
目前没有回答
相关问题 更多 >
编程相关推荐