如何将csv文件加载到配置单元表中?

5fjcxozz  于 2021-06-24  发布在  Hive
关注(0)|答案(0)|浏览(191)

我正在尝试使用python将csv从一个远程服务器加载到另一个服务器上的配置单元客户端:
我正在打开远程服务器上的csv文件:

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

现在我正在寻找使用pyhiveconnect将csv\u文件加载到配置单元(位于不同的服务器上)的命令;

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文件,而不保存在服务器上的实际文件

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题