python连接hive的方法-创新互联
创新互联www.cdcxhl.cn八线动态BGP香港云服务器提供商,新人活动买多久送多久,划算不套路!
创新互联建站是一家专注于做网站、网站设计与策划设计,宁德网站建设哪家好?创新互联建站做网站,专注于网站建设十载,网设计领域的专业建站公司;建站业务涵盖:宁德等地区。宁德做网站价格咨询:028-86922220python连接hive的方法?这个问题可能是我们日常学习或工作经常见到的。希望通过这个问题能让你收获颇深。下面是小编给大家带来的参考内容,让我们一起来看看吧!
一、下载hive提供的依赖包
将hive安装包下的lib/py中的文件拷贝到python的sys.path中的site_packages目录下,否则引用对应的包会报错,这个是使用hive提供的Python接口来调用hive客户端。
二、安装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连接hive的方法大概了解了吗?希望文章内容对大家有所帮助。如果想了解更多相关文章内容,欢迎关注创新互联-成都网站建设公司行业资讯频道。
标题名称:python连接hive的方法-创新互联
本文URL:http://azwzsj.com/article/dhphsd.html