Python脚本执行hive SQL命令
一、问题背景
将 hive SQL写入 Python 脚本，这样就可以将 Python 脚本设为定时任务，不用每次手动执行 hive SQL 语句。
二、解决方法
import os def run_sql(): cmd = """ beeline ******** -e " select * from example_db.example_table; " """ os.system(cmd) print(cmd)
解释：
beeline 后面省略的部分是登录 hive 的命令，我们公司使用 beeline 方式登录 hive。
把上方代码按照需求修改之后放入服务器上，按照本地 IDE 的执行 Python 的方式执行即可。
以上，问题解决~
