样例代码 使用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 = 10000,
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
