Pyhive Presto insert select * from not running

Question

我可以使用 PYHIVE 连接到 PRESTO 并选择数据回来就好了。我正在尝试使用 PYHIVE 在 presto 上运行“insert into x select from y”，但它没有运行。我确定我错过了一些简单的东西。

from pyhive import presto
import requests
from requests.auth import HTTPBasicAuth
import pandas as pd

req_kw = {'auth': HTTPBasicAuth(user, pw),'verify':False}

conn = presto.connect(host=ht,port=prt,protocol='https',catalog='hive',username=user,requests_kwargs=req_kw)

cursor  = conn.cursor()

query='select count(1) from dim.date_dim '
cursor.execute(query)
print(cursor.fetchall())

query='insert into flowersc.date_dim select * from dim.date_dim'
cursor.execute(query)

query='select count(1) from flowersc.date_dim '
cursor.execute(query)
print(cursor.fetchall())

没有错误发生

但结果显示没有加载数据

[(16624,)] [(0,)]

非常感谢任何帮助。

Answer 1

您需要检查（获取）结果

query='insert into flowersc.date_dim select * from dim.date_dim'
cursor.execute(query).next() # added .next()

这是必要的，因为 Presto 在 2018 年 5 月发生了变化 (https://github.com/prestosql/presto/commit/568449b8d058ed8281cc5277bb53902fd044cad7)。但验证查询结果也是一个好习惯，即检查您的INSERT 语句是否成功。