其实，

背景

最近在开发中遇到了一个场景。公司需要连接 Kerberos 认证的 Hive。正常情况下直接用 pyhive 就可以但发现 pyhive 使用的是非开源实现。在查询数据时容易出现 bug，而且修复时间很长。这一痛点促使我们决定采用 Python JD娱乐 方式来规避这一问题。

解决思路

Pytho n 有一个名为 jaydebeapi 的库，专门用于调用 JD娱乐 连接。我们使用它调用 JD娱乐 连接 Hive，并在中间做好 Kerberos 认证即可。

"""测试验证jaydebeapi连接Hive。采用Kerberos认证"""
import os
import jpype
import jaydebeapi
def main:
driver = "org.apache.hive.jdbc.HiveDriver"
HS2_HOST = "xxxx"
HS2_PORT = 10000
REALM = "xxxx"
url = (
从f"jdbc来看，hive2://{HS2_HOST}:{HS2_PORT}/default;"
f"principal=hive/xxxx@{REALM};sasl.qop=auth-conf;"
)
jdbc_path = "/opt/xxxx/"
if not jpype.isJVMStarted:
jpype.startJVM(
jpype.getDefaultJVMPath,f"-Djava.class.path={jdbc_path}/hive-jdbc.jar","-Djava.security.krb5.conf=./krb5.conf","-Djavax.security.auth.useSubjectCredsOnly=false",# 如需排查 Kerberos，可打开下一行：
# "-Dsun.security.krb5.debug=true"。)
# Kerberos 认证连接，无需 username/password
conn = jaydebeapi.connect
cursor = conn.cursor
sqlstr = "select * from xxx"
cursor.execute
result = cursor.fetchall
for r in result:
print
cursor.close
conn.close
if __name__ == "__main__":
main

注：当前运行环境已安装 Kerberos client 并完成认证； 'jdbc:hive2://{HS2_HOST}:{HS2_PORT}/default;principal=hive/xxxx@{REALM};sasl.qop=auth-conf;' 中的参数与集群相关，需要自行配置。

sasl.qop 参数说明：

• auth： 仅身份验证，不提供数据加密或完整性保护。老实说，
• auth-int： 身份验证 + 完整性保护；确保数据未被篡改，但不加密。
• auth-conf： 身份验证 + 完整性 + 机密性；提供完整加密，确保数据不被窃听。者需根据集群配置选择合适值。