创新互联Python教程:python如何连接hive
一、下载Hive提供的依赖包

为兰考等地区用户提供了全套网页设计制作服务,及兰考网站建设行业解决方案。主营业务为成都网站设计、成都做网站、兰考网站设计,以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!
将hive安装包下的lib/py中的文件拷贝到python的sys.path中的site_packages目录下,否则引用对应的包会报错,这个是使用hive提供的Python接口来调用hive客户端。
相关推荐:《Python入门教程》
二、安装pyhs2
控制台执行命令:
pip install pyhs2
如果安装不成功,安装上面提到的依赖包就可以了。
三、启动hive 的thrift
确保以下服务开启,默认端口是10000:
hive --service hiveserver
四、代码演示
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import pyhs2
with pyhs2.connect(host='10.104.111.33',
port=10000,
authMechanism="PLAIN",
user='bestfei',
password='password',
database='default') as conn:
with conn.cursor() as cur:
#Show databases
print "cur.getDatabases"
print cur.getDatabases()
print "-"*40
#Execute query
cur.execute("show databases")
#Return column info from query
print cur.getSchema()
print "-"*40
#Fetch table results
for i in cur.fetch():
print i 文章名称:创新互联Python教程:python如何连接hive
URL网址:http://www.jxjierui.cn/article/dhdcpjd.html


咨询
建站咨询
