品易云推流 关闭
文章详情页
文章 > Python基础教程 > python如何连接hive

python如何连接hive

Python 连接 hive

头像

爱喝马黛茶的安东尼

2019-10-26 15:39:472997浏览 · 0收藏 · 0评论

一、下载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
关注

关注公众号,随时随地在线学习

本教程部分素材来源于网络,版权问题联系站长!

底部广告图