python連接hive的方法

python連接hive的方法？這個(gè)問題可能是我們?nèi)粘W(xué)習(xí)或工作經(jīng)常見到的。希望通過這個(gè)問題能讓你收獲頗深。下面是小編給大家?guī)淼膮⒖純?nèi)容，讓我們一起來看看吧！

一、下載hive提供的依賴包

將hive安裝包下的lib/py中的文件拷貝到python的sys.path中的site_packages目錄下，否則引用對應(yīng)的包會(huì)報(bào)錯(cuò)，這個(gè)是使用hive提供的Python接口來調(diào)用hive客戶端。

二、安裝pyhs2

控制臺(tái)執(zhí)行命令：

pip install pyhs2

如果安裝不成功，安裝上面提到的依賴包就可以了。

三、啟動(dòng)hive 的thrift

確保以下服務(wù)開啟，默認(rèn)端口是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

感謝各位的閱讀！看完上述內(nèi)容，你們對python連接hive的方法大概了解了嗎？希望文章內(nèi)容對大家有所幫助。如果想了解更多相關(guān)文章內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道。