Python怎么写数据到hive中 - 问答

要将数据写入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()关闭连接。

0 赞

0 踩