1、实现代码如下：
import hdfs hdfs_ip = "ip:50070" try: client = hdfs.Client(hdfs_ip) //上传前hdfs指定路径下文件列表 print(client.list("hdfs完整路径")) client.upload('hdfs完整路径', '本地目录/文件名.csv') //上传后hdfs指定路径下文件列表，验证是否上传成功 print(client.list("hdfs完整路径")) except Exception as e: print(e)温馨提示： 本人联系方式： QQ：961094233 邮箱：961094233@qq.com
