Impyla是用于分布式查询引擎的HiveServer2实现(如Impala、Hive)的python客户端
1)安装impyla
pip install impyla
安装报错
解决办法:
根据提示下载对应的工具
https://visualstudio.microsoft.com/zh-hans/downloads/
直接下载安装即可
工具安装完成后,继续pip install impyla
安装成功
代码测试:
from impala.dbapi import connect conn = connect(host='xxx.xxx.xxx.xxx', port=21050) cur = conn.cursor() cur.execute('show databases;') database_list=cur.fetchall() for data in database_list: print(data)
OK 正常连接
参照以前的Mysql连接工具类,写了个连接Impala的工具类:
from impala.dbapi import connect class IMPALA: def __init__(self,host,port,user,pwd,db): self.host = host self.port = port self.user = user self.pwd = pwd self.db = db def __GetConnect(self): if not self.db: raise(NameError,"没有设置数据库信息") self.conn = connect(host=self.host,port=self.port,user=self.user,password=self.pwd,database=self.db) cur = self.conn.cursor() if not cur: raise(NameError,"连接数据库失败") else: return cur def ExecQuery(self,sql): cur = self.__GetConnect() cur.execute(sql) resList = cur.fetchall() #查询完毕后必须关闭连接 self.conn.close() return resList def ExecNonQuery(self,sql): cur = self.__GetConnect() cur.execute(sql) self.conn.commit() self.conn.close()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持小牛知识库。
本文向大家介绍Docker容器连接实现步骤解析,包括了Docker容器连接实现步骤解析的使用技巧和注意事项,需要的朋友参考一下 一般来说,容器启动后,我们都是通过端口映射来使用容器提供的服务,实际上,端口映射只是使用容器服务的一种方式,除了这种方式外,还可以使用容器连接的方式来使用容器服务。 例如,有两个容器,一个容器运行一个SpringBoot项目,另一个容器运行着mysql数据库,可以通过容器
本文向大家介绍Python接口开发实现步骤详解,包括了Python接口开发实现步骤详解的使用技巧和注意事项,需要的朋友参考一下 一、操作步骤 1. 导入:import flask,json 2. 实例化:api = flask.Flask(__name__) 3. 定义接口访问路径及访问方式:@api.route('/index',methods=['get/post/PUT/DELETE'])
本文向大家介绍Python简单实现词云图代码及步骤解析,包括了Python简单实现词云图代码及步骤解析的使用技巧和注意事项,需要的朋友参考一下 一、安装 wordcloud 二、加载包、设置路径 三、词云图示例 1、默认参数示例 如果 jupyter 没有图形输出,需要设置 jupyter 的图形显示方式 %matplotlib inline WordCloud() 词云图对象对应的画布默认长20
我们已经创建了一个能建立数据库连接的函数 connect_db ,但它本身并 不是很有用。总是创建或关闭数据库连接是相当低效的,所以我们会让连接 保持更长时间。因为数据库连接封装了事务,我们也需要确保同一时刻只有 一个请求使用这个连接。那么,如何用 Flask 优雅地实现呢? 这该是应用环境上场的时候了。那么,让我们开始吧。 Flask 提供了两种环境(Context):应用环境(Applicat
本文向大家介绍Centos7 yum安装mongodb实现步骤详解,包括了Centos7 yum安装mongodb实现步骤详解的使用技巧和注意事项,需要的朋友参考一下 简介 MongoDB 是一个基于分布式 文件存储的NoSQL数据库 由C++语言编写,运行稳定,性能高 旨在为 WEB 应用提供可扩展的高性能数据存储解决方案 查看官方网站 MongoDB特点 模式自由 :可以把不同结构的文档存储在
本文向大家介绍python脚本替换指定行实现步骤,包括了python脚本替换指定行实现步骤的使用技巧和注意事项,需要的朋友参考一下 python脚本替换指定行实现步骤 本文主要介绍了Python的脚本替换,由于工作的需要,必须对日志系统进行更新,这里在网上搜索到一篇文章比较不错,这里记录下,大家可以参考下, 工作中需要迁移代码,并把原来的日志系统更新到现在的格式,原来获取log的格