我想调用HDFS REST api上传文件,使用httplib
。我想调用HDFS REST api上传文件
我的程序创建了文件,但没有内容。
============================================== =======
这里是我的代码:
import httplib
conn=httplib.HTTPConnection("localhost:50070")
conn.request("PUT","/webhdfs/v1/levi/4?op=CREATE")
res=conn.getresponse()
print res.status,res.reason
conn.close()
conn=httplib.HTTPConnection("localhost:50075")
conn.connect()
conn.putrequest("PUT","/webhdfs/v1/levi/4?op=CREATE&user.name=levi")
conn.endheaders()
a_file=open("/home/levi/4","rb")
a_file.seek(0)
data=a_file.read()
conn.send(data)
res=conn.getresponse()
print res.status,res.reason
conn.close()
=========================== =======================
这里是返回:
307 TEMPORARY_REDIRECT 201创建
============================================= ============
好的,该文件已创建,但没有内容发送。
当我评论#conn.send(data)
时,结果是一样的,仍然没有内容。
也许文件读取或发送错误,不确定。
你知道这是怎么发生的吗?