python 如何调用hive

原创
ithorizon 7个月前 (09-30) 阅读数 33 #Python

Python调用Hive的方法

Python调用Hive主要可以通过PyHive或者HivePy两种库来实现,这两种库都是Python的第三方库,需要单独安装。

1、PyHive的安装和使用

PyHive是一个Python的第三方库,可以通过Python连接Hive并执行SQL语句,安装PyHive可以使用pip命令进行安装:

pip install pyhive

使用PyHive连接Hive并执行SQL语句的示例代码如下:

from pyhive import hive
连接Hive
conn = hive.Connection(host="localhost", port=10000, username="root")
执行SQL语句
cursor = conn.cursor()
cursor.execute("SELECT * FROM my_table")
rows = cursor.fetchall()
输出结果
for row in rows:
    print(row)

2、HivePy的安装和使用

HivePy是另一个Python的第三方库,也可以用于Python调用Hive,安装HivePy同样可以使用pip命令进行安装:

pip install hive-py

使用HivePy连接Hive并执行SQL语句的示例代码如下:

from hive_py import HiveConnection, TableValue, ArrayValue, MapValue, UnionValue
连接Hive
conn = HiveConnection(host="localhost", port=10000, username="root")
cursor = conn.cursor()
执行SQL语句
cursor.execute("SELECT * FROM my_table")
rows = cursor.fetchall()
输出结果
for row in rows:
    print(row)

是Python调用Hive的两种常见方法,具体使用哪种方法可以根据个人喜好和需求进行选择。



热门