更新时间:2024-06-05 GMT+08:00
分享

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

相关文档