python模块之 – subprocess执行unix/linux命令详解编程语言

#!/usr/bin/env python 
#coding:utf-8 
import os 
import sys 
import subprocess 
import time 
import signal 
TOMCAT_HOME="/usr/local/tomcat-fraud/" 
TOMCAT_PORT=8083 
remote_ip="123.56.219.121" 
remote_port="'-e ssh -p 6168'" 
try: 
backup_dir='/data/backup/' + sys.argv[1] + os.sep + time.strftime('%Y%m%d') 
except IndexError: 
print("example : python fraud-dev.sh < projectname >") 
if len(sys.argv) < 2: 
print("you must use like this : python fraud-dev.sh <projectname>") 
sys.exit() 
if not os.path.isdir(backup_dir): 
os.makedirs(backup_dir) 
print("Sucessfully created directory",backup_dir) 
else: 
print("directory alreaty exist") 
#备份的模块(将项目的war包从jenkins目录取下来放到本地目录.) 
def backup(): 
print("download fraud.war...") 
#Jenkins服务器存放war包的目录 
packge_dir="/root/.jenkins/workspace/fraud-dev/fraud-web/target/" 
remote_ssh = remote_ip + ":" + packge_dir + sys.argv[1] + ".war" 
print(remote_ssh) 
#remote_ssh = remote_ip + ":" + packge_dir 
rsyn="/usr/bin/sudo rsync -avH --progress %s %s %s" %(remote_port,remote_ssh,backup_dir) 
if subprocess.call(rsyn,shell=True) == 0: 
print("download fraud.war sucess...") 
else: 
print("同步代码失败，check...") 
#代码更新函数: 
def rsync_java(): 
target_dir=TOMCAT_HOME + "webapps/" 
#os.chdir(target_dir) 
subprocess.Popen("rm -rf *", shell=True, cwd=target_dir) 
time.sleep(3) 
print("开始更新代码中...") 
rsync_ssh="/usr/bin/sudo rsync -avH --progress %s %s" %(backup_dir,target_dir) 
if subprocess.call(rsync_ssh,shell=True) == 0: 
print("代码更新完成...") 
else: 
print("代码更新失败...") 
#启停Java服务. 
def kill_pid(pid): 
try: 
a = os.kill(pid, signal.SIGKILL) 
print("已杀死pid为%s的进程,返回值是:%s" % (pid, a)) 
except OSError: 
print("没有这个进程号") 
def start_java(): 
java_service= TOMCAT_HOME + "bin/startup.sh" 
os.system(java_service) 
time.sleep(5) 
print("tomcat 启动完成...") 
if __name__ == "__main__": 
backup() 
li = [] 
#cmd="/usr/sbin/lsof -i:80 |egrep -v PID | awk {'print $2'} |sort -nr|uniq" 
cmd="/usr/sbin/lsof -i:%s | grep java |awk {'print $2'}" %(TOMCAT_PORT) 
pid = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) 
# print(pid.stdout.readlines()) 
for m in pid.stdout.readlines(): 
li.append(int(m)) 
for i in li: 
kill_pid(i) 
time.sleep(3) 
print("开始上传代码中...") 
rsync_java() 
start_java()

#!/usr/bin/env python 
#coding:utf-8 
import os 
import time 
import subprocess 
packge_dir = "/root/.jenkins/workspace/shop-H5/" 
remote_ip = "59.110.164.99" 
remote_port = "'-e ssh -p 6168'" 
backup_dir = '/data/backup/' + time.strftime('%Y%m%d') 
source_dir = "shop-H5" 
def backup_php(): 
tgz = backup_dir + os.sep + "shop-H5_" + time.strftime('%Y%m%d%H') + '.tgz' 
backup_tgz = "tar -zcvf %s %s" % (tgz,source_dir) 
#print(time.strftime('%Y-%m-%d-%H:%M')) 
#print(backup_dir) 
if not os.path.exists(backup_dir): 
os.mkdir(backup_dir) 
print("Sucessfully created directory",backup_dir) 
print("开始备份代码中...") 
os.chdir('/opt') 
if subprocess.call(backup_tgz,shell=True) == 0: 
print("Successful backup to ", tgz) 
else: 
print("Backup FAILED!!") 
time.sleep(3) 
def rsync_php(): 
print("开始代码同步中...") 
remote_ssh = remote_ip + ":" + packge_dir 
rsyn = "/usr/bin/sudo rsync -avH --progress %s %s %s" %(remote_port,remote_ssh,source_dir) 
if subprocess.call(rsyn,shell=True) == 0: 
print("同步代码成功...") 
else: 
print("同步代码失败，check...") 
#递归改变目录的权限 
#os.chown(source_dir,509,509) 
mattr="chown -R phpci:phpci %s" %(source_dir) 
#subprocess.call(mattr,shell=True) 
subprocess.call(mattr,shell=True) 
if __name__ == "__main__": 
backup_php() 
rsync_php() 
PHP代码备份及上传

#!/usr/bin/env python 
#coding:utf-8 
import os 
import time 
import subprocess 
packge_dir = "/root/.jenkins/workspace/pre-php-p/" 
remote_ip = "59.110.164.99" 
remote_port = "'-e ssh -p 6168'" 
backup_dir= '/data/backup/' + time.strftime('%Y%m%d') 
source_dir="shop-H5" 
source_URL="/data/web/xd" 
def backup_php(): 
tagz = backup_dir + os.sep + source_dir + "_" + time.strftime('%Y%m%d%H') + '.tgz' 
print "tagz=",tagz 
backup_tgz = "tar -zcvf %s %s" %(tagz,source_dir) 
if not os.path.exists(backup_dir): 
os.mkdir(backup_dir) 
print("Sucessfully created directory",backup_dir) 
print("开始备份代码中...") 
os.chdir(source_URL) 
#os.system(backup_tgz) 
#subprocess.call(backup_tgz,shell=True) 
if subprocess.call(backup_tgz,shell=True) == 0: 
print  "Successful backup to ", tagz 
else: 
print "Backup FAILED!!" 
time.sleep(3) 
def rsync_php(): 
print("开始代码同步中...") 
remote_ssh = remote_ip + ":" + packge_dir 
time.sleep(3) 
rsyn="/usr/bin/sudo rsync -avH --progress --exclude=.git %s %s %s" %(remote_port,remote_ssh,source_dir) 
#print rsyn 
if subprocess.call(rsyn,shell=True) == 0: 
print("同步代码成功...") 
else: 
print("同步代码失败，check...") 
#os.chown(source_dir,504,504) 
mattr="chown -R phpci:phpci %s" %(source_dir) 
subprocess.call(mattr,shell=True) 
if __name__ == "__main__": 
backup_php() 
rsync_php()