我正在从python脚本运行配置单元查询。当我使用subprocess.getstatusoutput时,我能够运行它而没有任何问题,但是无法将结果存储到变量中。所以我试着用波本,我得到一个错误,说不能
dd1 = '10-Sep-12'
table = 'testing_table'
1> query = "select distinct(input__file__name) from <db_name>." + table + " where as_of_date =" +"'"+ dd1 +"'"+ " limit 2"
2> cmd = 'beeline -u "jdbc:hive2:<connection string>" -e "'+query + ';"'
3> stat, query_output = subprocess.getstatusoutput(cmd)
这是可行的,但是当我试图打印查询输出时,它会打印所有的输出(比如所有阶段的'info'标签和查询的确切o/p)
当我使用subprocess.popen或subprocess.check\u output时,出现如下错误,而不是getstatusoutput:
FileNotFoundError: [Errno 2] No such file or directory: 'beeline -u "<connection string>" -e "select distinct(input__file__name) from <db_name>.<table_name> where as_of_date =\'10-Sep-12\' limit 2;"'
1条答案
按热度按时间hec6srdp1#
attached是一个python代码段,用于从带有表列表的文件中读取数据,并对列表中的每个表运行配置单元查询,并使用subprocess将结果附加到文件中
cmd变量存储从子进程fns调用的要执行的命令,输出存储到变量中,该变量稍后写入文件。下一组步骤读取在第一个步骤中创建的文件,并执行另一个查询并写入另一个文件。