真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網站制作重慶分公司

python如何連接hive-創(chuàng)新互聯(lián)

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

在濂溪等地區(qū),都構建了全面的區(qū)域性戰(zhàn)略布局,加強發(fā)展的系統(tǒng)性、市場前瞻性、產品創(chuàng)新能力,以專注、極致的服務理念,為客戶提供成都網站設計、成都做網站 網站設計制作按需求定制設計,公司網站建設,企業(yè)網站建設,品牌網站制作,成都全網營銷,外貿網站建設,濂溪網站建設費用合理。

這篇文章將為大家詳細講解有關python 如何連接hive,文章內容質量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關知識有一定的了解。

python連接hive的幾種方式

·基于pyhive連接hive。

·基于impyla連接hive。

方法一:使用PyHive庫

安裝依賴包:其中sasl安裝可能會報錯,可以去https://www.lfd.uci.edu/~gohlke/pythonlibs/#sasl下載對應版本安裝。

pip install sasl
pip install thrift
pip install thrift-sasl
pip install PyHive

Python腳本代碼操作:

from pyhive import hive   # or import hive
conn = hive.Connection(host='****', port=****, username='****', database='****')
cursor.execute(''SELECT * FROM my_awesome_data LIMIT 10'')
for i in range(****):
    sql = "INSERT INTO **** VALUES ({},'username{}')".format(value, str(username))
    cursor.execute(sql)
  
# 下面是官網代碼:
from pyhive import presto  # or import hive
cursor = presto.connect('localhost').cursor()
cursor.execute('SELECT * FROM my_awesome_data LIMIT 10')
print(cursor.fetchone())
print(cursor.fetchall())

方法二:使用impyla庫

impyla依賴包:

pip install six
pip install bit-array
pip install thriftpy

為了支持Hive還需要以下兩個包:

pip install sasl
pip install thrift-sasl

可在Python PyPI中下載impyla及其依賴包的源碼

Python腳本代碼:

from impala.dbapi import connect 
conn = connect(host ='****',port = ****)
cursor = conn.cursor()
cursor.execute('SELECT * FROM mytable LIMIT 100')
print cursor.description   # 打印結果集的schema 
results = cursor.fetchall()

關于python 如何連接hive就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。


新聞標題:python如何連接hive-創(chuàng)新互聯(lián)
標題鏈接:http://weahome.cn/article/dhdchp.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部