pythonでデータをHiveに書き込む方法

1年 ago
綾乃, 一希
1 minute

pyhiveライブラリを使ってデータをHiveに書き込むには、まずライブラリのインストールが必要です。インストールには次のコマンドを実行します。

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()を使用して接続を閉じます。

bannerAds