任何人都可以指导我如何使用 Python 运行 .hql 查询。尝试了 Hiveutils lib,但它不存在于开发环境中。还有其他方法来执行查询吗?
您可以使用PyHive:PyHive 是 Presto 和 Hive 的 Python DB-API 和 SQLAlchemy 接口的集合。
示例:
from pyhive import hive
cursor = hive.connect('localhost').cursor()
cursor.execute('SELECT * FROM my_awesome_data LIMIT 10')
print(cursor.fetchone())
print(cursor.fetchall())
您可以尝试使用 pyhs2,尝试像下面给出的示例一样工作
import pyhs2
with pyhs2.connect(host='localhost',
port=10000,
authMechanism="PLAIN",
user='your_user',
password='your_password',
database='your_default_db') as conn:
with conn.cursor() as cur:
print cur.getDatabases()
cur.execute("select * from table")
#Return info from query
print cur.getSchema()
出现错误:找不到 pyhive 的匹配发行版。请指教
pip 安装 pyhive
收集 pyhive 警告:在连接因 'NewConnectionError('