新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
創(chuàng)新互聯(lián)Python教程:python如何連接hive
一、下載Hive提供的依賴包

為蘭考等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù),及蘭考網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、蘭考網(wǎng)站設(shè)計(jì),以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求,就會(huì)得到認(rèn)可,從而選擇與我們長期合作。這樣,我們也可以走得更遠(yuǎn)!
將hive安裝包下的lib/py中的文件拷貝到python的sys.path中的site_packages目錄下,否則引用對應(yīng)的包會(huì)報(bào)錯(cuò),這個(gè)是使用hive提供的Python接口來調(diào)用hive客戶端。
相關(guān)推薦:《Python入門教程》
二、安裝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 分享標(biāo)題:創(chuàng)新互聯(lián)Python教程:python如何連接hive
網(wǎng)頁地址:http://m.fisionsoft.com.cn/article/dhdcpjd.html


咨詢
建站咨詢
