RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
创新互联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