python 操作hive pyhs2方式

Python 可以通过 pyhs2 包在 Hive 中执行查询、创建表、插入数据等操作，下面是详细的操作步骤：

1. 安装 pyhs2

首先需要在本地安装 pyhs2 包，可以通过 pip 命令来安装：

pip install pyhs2

2. 建立连接

使用 pyhs2 包建立到 Hive 的连接，需要提供连接 Hive 的主机名、端口号、用户名、密码等信息如下：

import pyhs2

# 建立连接
conn = pyhs2.connect(
    host='localhost',
    port=10000,
    authMechanism='PLAIN',
    username='username',
    password='password',
    database='default'
)

其中，host 为 Hive 的主机名，port 为 Hive 的端口号，authMechanism 为认证方式，使用 PLAIN 表示使用明文认证方式，username 和 password 分别为 Hive 的用户名和密码，database 为默认使用的数据库，以上参数的具体值需要根据实际情况修改。

3. 查询数据

连接建立完成后，即可执行 Hive 中的 SQL 查询语句，使用 cursor 对象执行查询操作，示例代码如下：

# 获取 cursor
cursor = conn.cursor()

# 执行查询，返回结果集
cursor.execute('SELECT * FROM my_table')

# 获取查询结果
results = cursor.fetch()
for row in results:
    print(row)

以上示例代码中，使用 cursor 对象执行了一条 SQL 查询语句，并通过 fetch 方法获取查询结果，然后遍历输出结果集。可以根据实际需要构造不同的 SQL 查询语句。

4. 插入数据

使用 pyhs2 包也可以向 Hive 数据库中插入数据，示例代码如下：

# 插入数据
cursor.execute("INSERT INTO my_table (col1, col2) VALUES ('value1', 2)")

# 提交事务
conn.commit()

以上示例代码中，使用 execute 方法执行了一条 SQL 插入语句，插入一条数据到 my_table 表中，然后使用 commit 方法提交事务。

5. 关闭连接

在完成所有操作后，需要关闭与 Hive 的连接，示例代码如下：

# 关闭 cursor 对象
cursor.close()

# 关闭连接
conn.close()

以上即为使用 pyhs2 在 Python 中操作 Hive 的完整攻略，其中包含建立连接、查询数据、插入数据等操作，并且给出了具体的示例代码说明。