Hive Server2 连接¶
Hive Server2 连接类型支持 Hive Server2 集成。
Hive Server2 认证¶
使用 PyHive 连接到 Hive Server2。选择通过 LDAP、Kerberos 或自定义方式进行认证。
默认连接 ID¶
所有与 Hive Server2 相关的 Hook 和 Operator 默认使用 hiveserver2_default
。
配置连接¶
- 登录(可选)
指定您的 Hive Server2 用户名。
- 密码(可选)
指定您的 Hive 密码,用于 LDAP 和自定义认证。
- 主机(可选)
指定 Hive Server2 的主机节点。
- 端口(可选)
指定您的 Hive Server2 端口号。
- Schema(可选)
指定您希望通过 Hive Server2 连接的数据库名称。
- 额外参数(可选)
指定可在 Hive Server2 连接中使用的额外参数(以 JSON 字典形式)。以下参数均为可选:
auth_mechanism
指定 PyHive 的认证方式。可选择PLAIN
、LDAP
、KERBEROS
或Custom
。默认为PLAIN
。kerberos_service_name
如果使用 Kerberos 认证,指定 Kerberos 服务名称。默认为hive
。run_set_variable_statements
指定是否要运行 set variable 语句。默认为True
。
在环境变量中指定连接时,应使用 URI 语法。
注意,URI 的所有组件都应进行 URL 编码。
例如
export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP'