python调用shell命令小结

老爷子88

# -*- coding: utf8 -*-　　
import exceptions
　　
import subprocess
　　
import traceback
　　
class CalledCommandError(Exception):
　　
    def __init__(self, returncode, cmd, errorlog,output):
　　
        self.returncode = returncode
　　
        self.cmd = cmd
　　
        self.output = output
　　
        self.errorlog = errorlog
　　
    def __str__(self):
　　
        return "命令运行错误:'%s',返回值: %s,错误信息： %s" % (self.cmd, str(self.returncode) ,self.errorlog)
　　
def run_command_all(*popenargs, **kwargs):
　　
    allresult = {}
　　
    cmd = popenargs[0]
　　
    if 'stdout' in kwargs or 'stderr' in kwargs :
　　
        raise ValueError('标准输出和标准错误输出已经定义，不需设置。')
　　
    process = subprocess.Popen(stdout=subprocess.PIPE,shell=True,stderr = subprocess.PIPE,*popenargs, **kwargs)
　　
    output, unused_err = process.communicate()
　　
    retcode = process.poll()
　　
    if retcode:
　　
        #print retcode,cmd,unused_err,output
　　
        raise CalledCommandError(cmd,retcode,errorlog=unused_err,output=output)
　　
    allresult['cmd'] = cmd
　　
    allresult['returncode'] = retcode
　　
    allresult['errorlog'] = unused_err
　　
    allresult['outdata'] = output
　　
    return allresult
　　
if __name__ == '__main__':
　　
    cmd = 'hadoop fs -ls xxxx|wc -l'
　　
    try:
　　
        e=run_command_all(cmd)
　　
        print "ok"
　　
    except Exception,re:
　　
        print (str(re))
　　
        print "failed"
　　
        traceback.print_exc()