python - 在 Impyla 中执行 Hive 脚本

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 端口连接到 Hive。

默认端口：对于 Impala -> 21050 ，对于 Hive ->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())