您好,登錄后才能下訂單哦!
python連接hive的方法?這個問題可能是我們日常學習或工作經常見到的。希望通過這個問題能讓你收獲頗深。下面是小編給大家帶來的參考內容,讓我們一起來看看吧!
一、下載hive提供的依賴包
將hive安裝包下的lib/py中的文件拷貝到python的sys.path中的site_packages目錄下,否則引用對應的包會報錯,這個是使用hive提供的Python接口來調用hive客戶端。
二、安裝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連接hive的方法大概了解了嗎?希望文章內容對大家有所幫助。如果想了解更多相關文章內容,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。