1.连接Hive
import pandas as pd
from sqlalchemy.engine import create_engine
# 准备语句(不能带分号)
sql = '''
SELECT * FROM db.test LIMIT 10
'''
presto_engine = create_engine('presto://110.120.119.115:8866/hive')
# 获取数据
df = pd.read_sql(sql, presto_engine)
print(df)
df.to_csv(r'C:\Users\liuzw3\Desktop\output_files.csv',index=False,encoding='utf-8')
