溫馨提示×

Python怎么寫數據到hive中

小億
240
2023-12-08 16:13:44
欄目: 編程語言

要將數據寫入Hive中,可以使用Python中的pyhive庫。首先,確保已經安裝了pyhive庫??梢允褂靡韵旅钸M行安裝:

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
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女