Python怎么写数据到hive中

72次阅读

共计 750 个字符，预计需要花费 2 分钟才能阅读完成。

要将数据写入 Hive 中，可以使用 Python 中的 pyhive 库。首先，确保已经安装了 pyhive 库。可以使用以下命令进行安装：

pip install pyhive

接下来，可以使用以下代码示例将数据写入 Hive 中：

from pyhive import hive

# 连接到 Hive 服务器
conn = hive.Connection(host='localhost', port=10000, username='your_username')

# 创建一个 Hive 游标
cursor = conn.cursor()

# 创建一个表
create_table_query = '''
CREATE TABLE IF NOT EXISTS my_table (
    id INT,
    name STRING
)
'''
cursor.execute(create_table_query)

# 插入数据到表中
insert_query = '''
INSERT INTO my_table (id, name)
VALUES (1, 'Alice'), (2, 'Bob')
'''
cursor.execute(insert_query)

# 提交事务
conn.commit()

# 关闭连接
conn.close()

以上代码中，首先使用 hive.Connection() 函数连接到 Hive 服务器。然后，使用 conn.cursor() 函数创建一个 Hive 游标。然后，使用 Hive 查询语句创建表并插入数据。最后，使用 conn.commit() 提交事务，并使用 conn.close() 关闭连接。

丸趣 TV 网 – 提供最优质的资源集合！

正文完