方法一：使用PyHive庫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()

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的python调用hive与java调用区别_Python操作Hive的两种方法总结的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。