导入依赖

from pyhive import hive

创建连接

conn = hive.Connection(host='10.110.18.216', port='10000', username='root', password='root',
                           database='sparktest', auth='CUSTOM')

获取cursor

cur = conn.cursor()

执行sql

cur.execute("create table weather_patient_sample_01 as select * from weather_patient")

返回结果

cur.fetchall()