在Impyla中执行配置单元脚本

Question

我所见过的Impyla示例都是用于执行命令行查询的，

即等效于运行

hive -e 'select * from my_db.my_table'

Impyla中有没有能够运行以下内容的功能：

hive -f create_hive_table.hql \
     -hiveconf my_db=db1 \
     -hiveconf my_table=tbl1

Answer 1

我只是使用默认的HiveServer2端口连接到配置单元。

默认端口:用于Impala -> 21050，用于配置单元-> 10000

• 无安全性

conn = connect(host='myhost', port=10000, auth_mechanism="NOSASL")
cursor = conn.cursor()
cursor.execute('show databases')
print(cursor.fetchall())

• LDAP

conn = connect(host='myhost', port=10000, auth_mechanism='LDAP', password='ldap_pass', user='user', use_ssl=True)
cursor = conn.cursor()
cursor.execute('show databases')
print(cursor.fetchall())