文档首页/ MapReduce服务 MRS/ 开发指南（普通版_3.x）/ Hive开发指南（普通模式）/ 开发Hive应用/ 基于Python的Hive样例程序
更新时间：2024-08-05 GMT+08:00
查看PDF
分享

基于Python的Hive样例程序

功能介绍

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

样例代码

使用Python方式提交数据分析任务，参考样例程序中的“hive-examples/python-examples/pyCLI_sec.py”。
  1. 导入HAConnection类。 
     from pyhs2.haconnection import HAConnection
  2. 声明HiveServer的IP地址列表。本例中hosts代表HiveServer的节点，xxx.xxx.xxx.xxx代表业务IP地址。 
    hosts = ["xxx.xxx.xxx.xxx", "xxx.xxx.xxx.xxx"]

    如果HiveServer实例被迁移，原始的示例程序会失效。在HiveServer实例迁移之后，用户需要更新示例程序中使用的HiveServer的IP地址。

  3. 在HAConnection的第三个参数填写正确的用户名，密码可以不填写。创建连接，执行HQL，样例代码中仅执行查询所有表功能，可根据实际情况修改HQL内容，输出查询的列名和结果到控制台。 
     try:
    with HAConnection(hosts = hosts,
                       port = 21066,
                       authMechanism = "PLAIN",
                       user='root',
                       password='******') as haConn:
        with haConn.getConnection() as conn:
            with conn.cursor() as cur:
                # Show databases
                print cur.getDatabases()
                # Execute query
                cur.execute("show tables")
                # Return column info from query
                print cur.getSchema()
                # Fetch table results
                for i in cur.fetch():
                    print i
except Exception, e:
    print e
父主题： 开发Hive应用