Python操作Hive的两种方法总结
发布时间：2019-09-22 08:09:12编辑：auto阅读（3826）
方法一：使用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及其依赖包的源码
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内置ssl模块编程（1）
下一篇： python 常用类库！
- openvpn linux客户端使用
48615
- H3C基本命令大全
47605
- openvpn windows客户端使用
38400
- H3C IRF原理及 配置
35620
- Python exit()函数
30069
- openvpn mac客户端使用
26798
- python全系列官方中文文档
25799
- 1.常用turtle功能函数
20685
- python 获取网卡实时流量
20428
- python 获取Linux和Windows硬件信息
18828
- 基于Qwen3-8B微调小说模型
112°
- pythonp爬虫-fanqienovel字体反爬实战
191°
- 大模型基础架构
225°
- AI多模态- Janus-Pro-7B模型推理微调,融合实战2
248°
- Selenium加载用户目录爬取某宝电商数据
244°
- Scrapy对接Pyppeteer
253°
- WSL从C盘迁移到D盘
287°
- AI多模态- Janus-Pro-7B模型本地部署1
341°
- Dify+Ollama+deepseek部署本地大模型
467°
- Ubuntu上安装部署Dify
448°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
