Python連線Impala實現步驟解析
阿新 • • 發佈:2020-08-05
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()
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。