pip install hdfs

python 讀取hdfs目錄或文件

import hdfs client =hdfs.Client('http://10.10.1.4:50070')fileDir='/user/hive/warehouse/house.db/dm_house/dt=201800909'try: status=client.status(fileDir,False) if status: print (status) rst=client.download(fileDir,'/home/dev/gewei') print (rst)exception Exception as e: print (e)

補(bǔ)充知識(shí)：用python訪問(wèn)hdfs出現(xiàn)webhdfs找不到的情況

有可能是webhdfs服務(wù)沒有開啟

向hdfs-site.xml文件中添加屬性：

<property> <name>dfs.webhdfs.enabled</name> <value>true</value> </property>

可以使用如下命令檢測(cè)，

獲得目錄的列表：

curl -i 'http://Hadoop:50070/webhdfs/v1/?user.name=hadoop&op=LISTSTATUS'

以上這篇python訪問(wèn)hdfs的操作就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持好吧啦網(wǎng)。