创新互联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
当前网址:http://www.gawzjz.com/qtweb/news31/198081.html

成都网站建设公司_创新互联,为您提供云服务器全网营销推广定制开发微信公众号网站维护自适应网站

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联