python如何连接hive

一、下载hive提供的依赖包

将hive安装包下的lib/py中的文件拷贝到python的sys.path中的site_packages目录下，否则引用对应的包会报错，这个是使用hive提供的Python接口来调用hive客户端。

相关推荐：《Python入门教程》

二、安装pyhs2

控制台执行命令：

pipinstallpyhs2

如果安装不成功，安装上面提到的依赖包就可以了。

三、启动hive 的thrift

确保以下服务开启，默认端口是10000：

hive--servicehiveserver

四、代码演示

#!/usr/bin/python
#-*-coding:UTF-8-*-
importpyhs2
withpyhs2.connect(host='10.104.111.33',
port=10000,
authMechanism="PLAIN",
user='bestfei',
password='password',
database='default')asconn:
withconn.cursor()ascur:
#Showdatabases
print"cur.getDatabases"
printcur.getDatabases()
print"-"*40

#Executequery
cur.execute("showdatabases")
#Returncolumninfofromquery
printcur.getSchema()
print"-"*40
#Fetchtableresults
foriincur.fetch():
printi