需要借助exe_command函數，該函數通過subprocess執行 shell 命令，并實時打印輸出。

from subprocess import Popen, PIPE, STDOUTdef exe_command(command):"""執行 shell 命令并實時打印輸出:param command: shell 命令:return: process, exitcode"""print(command)process = Popen(command, stdout=PIPE, stderr=STDOUT, shell=True)with process.stdout:for line in iter(process.stdout.readline, b''):print(line.decode().strip())exitcode = process.wait()return process, exitcodedef exe_sql_command(sql_command, redirect=None):"""執行 hive sql 命令并轉儲到文件:param sql_command: sql 命令:param redirect: 是否重定向輸出到文件:return: process, exitcode"""command = "hive -e \"%s\"" % sql_commandif redirect:command += f" > {redirect}"return exe_command(command)def exe_sql_file(sql_file, redirect=None):"""執行 hive sql 文件并轉儲到文件:param sql_file: sql 文件:param redirect: 是否重定向輸出到文件:return: process, exitcode"""command = f"hive -f {sql_file}"if redirect:command += f" > {redirect}"return exe_command(command)

總結

以上是生活随笔為你收集整理的Python执行 SQL 命令并实时打印输出的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。