如何将CSV文件加载到Hive表中？

编程问答 2022-08-16

问题描述

我正在尝试使用Python将CSV从1个远程服务器加载到另一台服务器上的Hive客户端：

我正在远程服务器上打开CSV文件：

with open("/path/to/csv/file/" +self.file_to_load,"rb") as file:
    csv_file = file.read()

现在，我正在寻找使用pyhive connect将csv_file加载到Hive（位于其他服务器上）的命令； 

conn_h = hive.connect(host=self.hive_host,port=10000,auth='NONE',username=self.user)
    
query = "LOAD LOCAL DATA INPATH 'file://" + self.path_to_file + "' OVERWRITE INTO TABLE " + self.tgt_hive_table
conn_h.cursor.execute(query)

我正在寻找一种方法来加载csv文件而不将实际文件保存在服务器上

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

hivelinuxlinuxpyhivepython