Python怎么寫數(shù)據(jù)到hive中

150次閱讀

共計 750 個字符，預(yù)計需要花費(fèi) 2 分鐘才能閱讀完成。

要將數(shù)據(jù)寫入 Hive 中，可以使用 Python 中的 pyhive 庫。首先，確保已經(jīng)安裝了 pyhive 庫。可以使用以下命令進(jìn)行安裝：

pip install pyhive

接下來，可以使用以下代碼示例將數(shù)據(jù)寫入 Hive 中：

from pyhive import hive

# 連接到 Hive 服務(wù)器
conn = hive.Connection(host='localhost', port=10000, username='your_username')

# 創(chuàng)建一個 Hive 游標(biāo)
cursor = conn.cursor()

# 創(chuàng)建一個表
create_table_query = '''
CREATE TABLE IF NOT EXISTS my_table (
    id INT,
    name STRING
)
'''
cursor.execute(create_table_query)

# 插入數(shù)據(jù)到表中
insert_query = '''
INSERT INTO my_table (id, name)
VALUES (1, 'Alice'), (2, 'Bob')
'''
cursor.execute(insert_query)

# 提交事務(wù)
conn.commit()

# 關(guān)閉連接
conn.close()

以上代碼中，首先使用 hive.Connection() 函數(shù)連接到 Hive 服務(wù)器。然后，使用 conn.cursor() 函數(shù)創(chuàng)建一個 Hive 游標(biāo)。然后，使用 Hive 查詢語句創(chuàng)建表并插入數(shù)據(jù)。最后，使用 conn.commit() 提交事務(wù)，并使用 conn.close() 關(guān)閉連接。

丸趣 TV 網(wǎng) – 提供最優(yōu)質(zhì)的資源集合！

正文完