python 鏈接impala執行SQL

項目中用python來鏈接impala數據庫最常見，一個簡單的鏈接，獲取結果。

#!/usr/bin/python
# -*- coding:utf-8 -*-
from impala.dbapi import connect
import sys

reload(sys)
sys.setdefaultencoding("utf8")


def impala_conn_exec(sql):
  conn = connect(host='192.168.x.xx', port=21050)
  cur = conn.cursor()
  cur.execute(sql)
  data_list=cur.fetchall()
  return data_list

sql = "select pk_value,send from  intf_trade_log t where pk_value='00033015017DC9F468FF0E9ABD8A582C'"
now_num = impala_conn_exec(sql)
print now_num

可以對結果做加工，取出來自己想要的格式。