基于Python3的Hive样例程序

功能介绍

本章节介绍如何使用Python3连接Hive执行数据分析任务。

样例代码

以下分析任务示例在“hive-examples/python3-examples/pyCLI_nosec.py”文件中。

1. 导入hive类

   from pyhive import hive

2. 创建JDBC连接：

   connection = hive.Connection(host='hiveserverIp', port=hiveserverPort, username='hive', database='default', auth=None, kerberos_service_name=None, krbhost=None)

   需按照实际环境修改以下参数：

   • hiveserverIp：替换为实际需要连接的HiveServer节点IP地址，可登录FusionInsight Manager，选择“集群 > 服务 > Hive > 实例”查看。
   • hiveserverPort：需要替换为Hive服务的端口，可在FusionInsight Manager界面，选择“集群 > 服务 > Hive > 配置”，在搜索框中搜索“hive.server2.thrift.port”查看，默认值为“10000”。
3. 执行SQL语句，样例代码中仅执行查询所有表功能，可根据实际情况修改HQL内容。

   cursor = connection.cursor()
   cursor.execute('show tables')

4. 获取结果并输出

   for result in cursor.fetchall():
       print(result)