脚本实现:从 HIVE 中导入数据到 MYSQL
代码如下:
import os import pymysql hive_sql = """ beeline -u jdbc:hive2://10.5.145.113:10000 -n 用户名 -p 密码 --showHeader=false --outputformat=csv2 -e " SELECT * from table名; " """ result = os.popen(hive_sql) values = [x[:-1].split(',') for x in result] db = pymysql.connect('IP地址', '用户名', '密码', '库名') cursor = db.cursor() #创建一个游标对象 mysql_sql = "insert into 库名.表名(col2, col2, col3, col4) values {}".format( ",".join('("{}", "{}", {}, "{}")'.format(x[0], x[1],x[2],x[3]) for x in values) ) cursor.execute(mysql_sql) db.commit() res = cursor.fetchall() print(res) db.close()
以上,问题解决~