創(chuàng)新互聯(lián)www.cdcxhl.cn八線動(dòng)態(tài)BGP香港云服務(wù)器提供商，新人活動(dòng)買多久送多久，劃算不套路！

創(chuàng)新互聯(lián)建站是一家專注于做網(wǎng)站、網(wǎng)站設(shè)計(jì)與策劃設(shè)計(jì),寧德網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)建站做網(wǎng)站,專注于網(wǎng)站建設(shè)十載,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:寧德等地區(qū)。寧德做網(wǎng)站價(jià)格咨詢:028-86922220

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)注創(chuàng)新互聯(lián)-成都網(wǎng)站建設(shè)公司行業(yè)資訊頻道。

文章題目：python連接hive的方法-創(chuàng)新互聯(lián)
標(biāo)題URL：http://weahome.cn/article/dhphsd.html