码迷,mamicode.com
首页 > 编程语言 > 详细

Python3 操作 HDFS

时间:2018-03-17 12:16:26      阅读:227      评论:0      收藏:0      [点我收藏+]

标签:Python   pyhdfs   

【第三方包】


【功能】


#encoding: utf-8
#author: walker
#date: 2018-03-17 
#summary: 利用 pyhdfs 重命名 hdfs 文件或目录

import os, sys, time
from pyhdfs import HdfsClient

SrcPath = '/test/xxx'
DstPath = '/test/yyy'
NameNode = 'nn1.example.com:50070,nn2.example.com:50070'


# 将 SrcPath 改名为 DstPath
def Rename(SrcPath, DstPath):
	fs = HdfsClient(hosts=NameNode)
	if not fs.exists(SrcPath):
		print('Error: not found %s' % SrcPath)
		sys.exit(-1)
		
	print('Reanme ... \n%s\n -> \n%s \n' % (SrcPath, DstPath))
	
	fs.rename(SrcPath, DstPath)
	
	
if __name__ == '__main__':
	Rename(SrcPath, DstPath)


*** walker ***




Python3 操作 HDFS

标签:Python   pyhdfs   

原文地址:http://blog.51cto.com/walkerqt/2087839

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!