MapReduce服务 MRS-Python访问Hive样例程序:样例代码

时间：2023-11-01 16:19:45

MapReduce服务 MRS

样例代码

使用Python方式提交数据分析任务，参考样例程序中的“hive-examples/python-examples/pyCLI_sec.py”。

导入HAConnection类。

 from pyhs2.haconnection import HAConnection

声明HiveServer的IP地址列表。本例中hosts代表HiveServer的节点，xxx.xxx.xxx.xxx代表业务IP地址。
```
hosts = ["xxx.xxx.xxx.xxx", "xxx.xxx.xxx.xxx"] 
```
如果HiveServer实例被迁移，原始的示例程序会失效。在HiveServer实例迁移之后，用户需要更新示例程序中使用的HiveServer的IP地址。

在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 iexcept Exception, e:    print e