PHP代码更新:
#!/usr/bin/env python
# -*- coding:utf-8 -*-
from fabric.api import *
from fabric.context_managers import *
from fabric.contrib.console import confirm
from fabric.colors import *
import time,sys,os
#==============登录远程主机变量设置====================
env.hosts=['opuser@10.0.0.111:22','opuser@10.0.0.112:22','opuser@10.0.0.115:22']
#env.password='1234'
#===============更新程序变量设置=======================
env.dev_dir='/app/webapps/'
env.pro_backup_date=time.strftime("%Y%m%d%H%M")
env.deploy_dir='/opt/app/webapps/'
env.pre_deploy_dir='/opt/app/prewebapps/'
env.deploy_tmp_dir='/home/opuser/upload/'
env.deploy_backup_dir='/data01/backup/php'
env.pro_name=prompt("please input programe name:",default="opuser.test.com")
env.pro_versionID=prompt("please input versionID:",default="0.0.0.0")
env.sourceProdRoot='/opt/app/webapps2/'
@task
def backup_task():
print red("Start to backup programe...")
env.pro_backup_name=prompt("Please input backup project name:",default="opuser.test.com")
with settings(warn_only=True):
run("cd %s && tar -czf %s.%s.backup.tar.gz --exclude %s/logs %s" % (env.deploy_dir,env.pro_backup_name,env.pro_backup_date,env.pro_backup_name,env.pro_backup_name))
run("cd %s && mv %s.%s.backup.tar.gz %s" % (env.deploy_dir,env.pro_backup_name,env.pro_backup_date,env.deploy_backup_dir))
print green("Backuped project packages success! ")
#@runs_once
@task
def tar_task():
print yellow("Start to tar source package...")
local("cd %s%s && rm -rf %s/index.php && tar -czf %s.tar.gz --exclude=logs --exclude .svn %s" % ( env.dev_dir,env.pro_name,env.pro_versionID,env.pro_name,env.pro_versionID))
print green("Creating source packages success!")
@task
def put_update_task():
run("mkdir -p /home/opuser/upload/%s" % (env.pro_name))
env.deploy_full_path=env.deploy_tmp_dir + env.pro_name
with settings(warn_only=True):
result = put(env.dev_dir + env.pro_name +"/"+ env.pro_name +".tar.gz",env.deploy_full_path)
if result.failed and not confirm("put file failed,Continue[Y/N]?"):
abort("Aborting file put task!")
with settings(warn_only=True):
lmd5=local("md5sum /app/webapps/%s/%s.tar.gz" % (env.pro_name,env.pro_name),capture=True).split(' ')[0]
rmd5=run("md5sum /home/opuser/upload/%s/%s.tar.gz" % (env.pro_name,env.pro_name)).split(' ')[0]
if lmd5==rmd5:
print "OK"
else:
print "ERROR"
with cd(env.deploy_full_path):
run("tar xf %s.tar.gz && cd %s && \cp -rf * %s%s/" % (env.pro_name,env.pro_versionID,env.deploy_dir,env.pro_name))
run("tar xf %s.tar.gz && cd %s && \cp -rf * %s%s/" % (env.pro_name,env.pro_versionID,env.pre_deploy_dir,env.pro_name))
run("mv %s %s" % (env.pro_versionID,env.pro_backup_date))
run("rm -rf %s*" % (env.pro_name))
print red("delete source tar file....")
#time.sleep(2)
with cd (env.dev_dir):
local("cd /app/webapps/%s && rm -rf %s.tar.gz" % (env.pro_name,env.pro_name))
@runs_once
@task
def rollback():
confirm("you are sure to rollback this project? Continue")
print yellow("Start to rollback project...")
with cd("/data/backup/php"):
run("ls -l")
env.rollback_pro_name=prompt("rollback project name:")
run("cd %s && tar -xf %s -C %s" % (env.deploy_backup_dir,env.rollback_pro_name,env.deploy_dir))
print green("rollback project success!")
@task
def checkcode():
#env.sourceLatestVersion=run("ls -lt /home/opuser/upload/%s/|awk '{print $9}'|grep -v ^$|head -n 1" % (env.pro_name))
#env.staticLatestVersion=run("ls -lt /home/opuser/upload/res.spp.com|awk '{print $9}'|grep -v ^$|head -n 1")
with cd("/server/scripts"):
# run("./deploy -alsologtostderr=true -bakLimit=7 -sourceProdRoot=%s%s -sourceDevRoot=%s%s -staticDevRoot=%s/ -staticProdRoot=%s -staticRelativeDirs=%s" % (env.sourceProdRoot,env.pro_name,env.sourceDevRoot,env.pro_name,env.staticDevRoot,env.staticProdRoot,env.staticRelativeDirs))
run("./deploy -alsologtostderr=true")
@task
def go():
#backup_task()
tar_task()
put_update_task()
#checkcode()
JAVA代码更新:
#!/usr/bin/env python
from fabric.api import *
from fabric.colors import *
from fabric.context_managers import *
from fabric.contrib.console import confirm
import time,os
env.hosts=['10.0.0.13','10.0.0.11','10.0.0.12']
env.user="opuser"
#env.password='Passw0d@!W'
env.port="52113"
env.app_local_dir="/app/webapps/app/java/"
env.backup_date=time.strftime("%Y%m%d%H%M")
env.pro_backup_dir="/data01/backup/java"
env.pro_name=prompt("please input app name:")
env.remote_app_dir="/opt/app/server/"
env.upload_temp_dir="/home/opuser/upload/"
@task
def backup_task():
run("cd %s%s/webapps && tar -czf %s.%s.tar.gz *.war && mv %s.%s.tar.gz %s" % (env.remote_app_dir,env.pro_name,env.pro_name,env.backup_date,\
env.pro_name,env.backup_date,env.pro_backup_dir))
print "backup app success!!!"
time.sleep(3)
print red("Ready to upload Java update package.....")
time.sleep(3)
@task
def upload_task():
run("mkdir -p /home/opuser/upload/%s" % (env.pro_name))
env.deploy_full_path=env.upload_temp_dir + env.pro_name
with settings(warn_only=True):
result = put(env.app_local_dir + env.pro_name +"/"+ "*.war",env.deploy_full_path)
lmd5=local("md5sum /app/webapps/app/java/%s/*.war" % (env.pro_name),capture=True).split(' ')[0]
rmd5=run("md5sum /home/opuser/upload/%s/*.war" %(env.pro_name)).split(' ')[0]
if lmd5==rmd5:
print "OK"
else:
print "ERROR"
#time.sleep(5)
print green("Start off Tomcat service and update service packs.....")
time.sleep(5)
@task
def shutdown_and_update():
#Close Tomcat
print red("start shutdown the %s...." % (env.pro_name))
time.sleep(3)
env.remote_app_pid=run("ps xua|grep %s|grep -v grep|awk '{print $2}'|tail -1" %(env.pro_name))
if len(env.remote_app_pid)==0:
#Delete the old version
print red("start delete war packge.....")
time.sleep(3)
run("cd %s%s/webapps && rm -rf *" % (env.remote_app_dir,env.pro_name))
#Update the new version
print green("Start update app ....")
run("cd /home/opuser/upload/%s && cp *.war %s%s/webapps" % (env.pro_name,env.remote_app_dir,env.pro_name))
time.sleep(3)
run("cd /home/opuser/upload/%s && mv *.war %s-%s-backup " % (env.pro_name,env.pro_name,env.backup_date))
time.sleep(5)
print green("Update successfull.....please run to the app")
else:
run("cd %s%s && ./bin/shutdown.sh" % (env.remote_app_dir,env.pro_name))
env.remote_app_pid=run("ps xua|grep %s|grep -v grep|awk '{print $2}'|tail -1" %(env.pro_name))
if len(env.remote_app_pid)==0:
print "%s is shutdown % (env.pro_name)"
run("cd %s%s/webapps && rm -rf *" % (env.remote_app_dir,env.pro_name))
#Update the new version
print green("Start update app ....")
run("cd /home/opuser/upload/%s && cp *.war %s%s/webapps" % (env.pro_name,env.remote_app_dir,env.pro_name))
time.sleep(3)
run("cd /home/opuser/upload/%s && mv *.war %s-%s-backup " % (env.pro_name,env.pro_name,env.backup_date))
time.sleep(5)
print green("Update successfull.....please run to the app")
else:
env.remote_app_pid=run("ps xua|grep %s|grep -v grep|awk '{print $2}'|tail -1" %(env.pro_name))
print "%s pid will be killed next .... "% (env.pro_name)
run("/bin/kill -9 %s" % (env.remote_app_pid))
time.sleep(5)
print green("the app %s has been shutdown" % (env.pro_name))
run("cd %s%s/webapps && rm -rf *" % (env.remote_app_dir,env.pro_name))
#Update the new version
print green("Start update app ....")
run("cd /home/opuser/upload/%s && cp *.war %s%s/webapps" % (env.pro_name,env.remote_app_dir,env.pro_name))
time.sleep(3)
run("cd /home/opuser/upload/%s && mv *.war %s-%s-backup " % (env.pro_name,env.pro_name,env.backup_date))
time.sleep(5)
print green("Update successfull.....please run to the app")
print yellow("###################################################")
print green(" \n")
@task
def start_task():
print green("starting app ....")
time.sleep(3)
run("set -m;%s%s/bin/startup.sh" % (env.remote_app_dir,env.pro_name))
time.sleep(5)
env.remote_app_pid=run("ps xua|grep %s|grep -v grep|awk '{print $2}'|tail -1" %(env.pro_name))
#print env.remote_app_pid
if len(env.remote_app_pid)!=0:
print blue("%s is startup successfull the pid is %s....."% (env.pro_name,env.remote_app_pid))
@task
def go():
backup_task()
upload_task()
shutdown_and_update()
start_task()
