python hive数据库连接,python导入数据到hive
大蟒连接储备的几种方式
基于pyhive连接蜂巢。
基于英皮拉连接蜂巢。
方法一:使用PyHive库
安装依赖包:其中简单认证和安全层安装可能会报错,可以去https://www.lfd.uci.edu/~gohlke/pythonlibs/#sasl下载对应版本安装。
pipinstallsasl
pipinstallthrift
pipinstallthrift-sasl
pipinstallPyHive相关推荐: 《Python基础教程》
计算机编程语言脚本代码操作:
from pyhiveimporthive #或importhive
连接=蜂巢。连接(主机=*** ,端口=***,用户名=*** ,数据库=*** )
光标。执行( SELECT * from my _ awesome _ data limit 10 )
foriinrange(****):
sql= INSERTINTO * * * *值({},用户名{} ) .格式(值,字符串(用户名))
游标。执行(sql)
#下面是官网代码:
来自pyhiveimportpresto #或importhive
光标=presto。连接( localhost ).光标()
光标。执行( SELECT * from my _ awesome _ data limit 10 )
print(cursor.fetchone())
打印(光标。fetchall())方法二:使用impyla库
英皮拉依赖包:
管道安装六
pipinstallbit-数组
管道安装为了支持储备还需要以下两个包:
pipinstallsasl
pipinstallthrift-sasl可在Python PyPI中下载英皮拉及其依赖包的源码
计算机编程语言脚本代码:
fromimpala.dbapiimportconnect
conn=连接(主机= * * * * *,端口=* * * * *)
cursor=conn.cursor()
光标。执行( SELECT * from my table limit 100 )
打印光标。描述#打印结果集的计划
results=cursor.fetchall()
郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。