当前位置: 首页 > 编程笔记 >

Python连接Impala实现步骤解析

奚瑾瑜
2023-03-14
本文向大家介绍Python连接Impala实现步骤解析,包括了Python连接Impala实现步骤解析的使用技巧和注意事项,需要的朋友参考一下

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的格