Jenkins持续集成－自动化部署脚本的实现《python》
# -*- coding: utf-8 -*-#
!/usr/bin/python
#
########################################################################
#
File Name: Jenkins_Project_Deploy.py
#
Program function: ueed for deployment code in CI server.
#
Author:Jeson
#
mail:jeson@imoocc.com
#
Created Time: 一6/20 19:24:33 2016
#
========================================================================
import ConfigParser
import sys
from sys import argv
import paramiko
def Gennerate_cmd(Project_Name,CI_IP,Project_Code_File,Project_Exclude_File,Project_Backup_Dir,Project_Deploy_Path,Project_Start_Command,Project_Log_Path):
cmd = []
#生成备份命令
if Project_Backup_Dir:
#生成备份原有文件
cmd.append("mkdir -p /opt/")
cmd.append("rsync -avzP %s %s && touch /tmp/CI_%s_backuptrue"%(Project_Deploy_Path,Project_Backup_Dir,Project_Name))
#生成关闭原有进程命令
cmd.append('test -e /tmp/CI_%s_backuptrue && ps -auxgrep "name:%s"grep -v grepawk \'{print $2}\'xargs kill'%(Project_Name,Project_Name))
#生成命令－确认原来服务已经顺利关闭
cmd.append('ps -auxgrep "name:%s"grep -v grepawk \'{print $2}\'&& touch /tmp/CI_killSuccps -auxgrep "name:%s"grep -v grepawk \'{print $2}\'xargs kill -9'%(Project_Name,Project_Name))
#生成命令－用于同步新的代码文件
if Project_Code_File == "":
cmd.append('test -e "/tmp/CI_%s_killSucc" && rsync -avzP --delete-after --exclude "{%s}" %s::%s %s'%(Project_Name,Project_Exclude_File,CI_IP,Project_Name,Project_Deploy_Path))
else:
cmd.append('test -e "/tmp/CI_%s_killSucc" && rsync -avzP --delete-after --exclude "{%s}" %s::%s/%s %s'%(Project_Name,Project_Exclude_File,CI_IP,Project_Name,Project_Code_File,Project_Deploy_Path))
#生成命令－用于启动服务
cmd.append(Project_Start_Command)
#生成命令－查看服务启动后的日志
cmd.append('tail -n 200 -f %s'%Project_Log_Path)
#生成命令－清理此次生成的临时文件
# cmd.append('rm -f /tmp/\*%s\*'%Project_Name)
return cmd
def Login_Execute_Command(Project_IP,Project_Login_Port,Project_Login_User,Login_ISA_Key,cmds):
Project_Port = int(Project_Login_Port) if Project_Login_Port else 22
if Project_IP and Project_Login_User and Login_ISA_Key:
key = paramiko.RSAKey.from_private_key_file(Login_ISA_Key)
s = paramiko.SSHClient()
s.load_system_host_keys()
s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
s.connect(hostname=Project_IP,port=Project_Port,username=Project_Login_User,pkey=key)
for cmd_item in cmds:
stdin,stdout,stderr=s.exec_command(cmd_item)
print stdout.read()
return True
else:
return false
def main():
if len(argv) > 2:
Config_File = argv if argv else "./Jenkins_Project_Deploy.conf "
Project_Name = argv if argv else ""
else:
print "Error 0:Input argv format error! ./Jenkins_Project_Deploy.py ./test.conf testname"
sys.exit()
try:
cf = ConfigParser.ConfigParser()
cf.read(Config_File)
CI_IP = cf.get(Project_Name, "CI_IP")
Project_Code_File = cf.get(Project_Name, "Project_Code_File")
Project_Exclude_File = cf.get(Project_Name, "Project_Exclude_File")
Project_Backup_Dir = cf.get(Project_Name, "Project_Backup_Dir")
Project_Deploy_Path = cf.get(Project_Name, "Project_Deploy_Path")
Project_Start_Command = cf.get(Project_Name, "Project_Start_Command")
Project_Log_Path = cf.get(Project_Name, "Project_Log_Path")
execute_command = Gennerate_cmd(Project_Name,CI_IP,Project_Code_File,Project_Exclude_File,Project_Backup_Dir,Project_Deploy_Path,Project_Start_Command,Project_Log_Path)
print "{Step 1: Command collected over!}",execute_command
Project_IP = cf.get(Project_Name, "Project_IP")
Project_Login_Port = cf.get(Project_Name, "Project_Login_Port")
Project_Login_User = cf.get(Project_Name, "Project_Login_User")
Login_ISA_Key = cf.get(Project_Name, "Login_ISA_Key")
except Exception as e:
print "Error 1: %s file open or read error!"%Config_File
sys.exit()
print "{Step 2:Prepare to loging...}",Project_IP
result = Login_Execute_Command(Project_IP,Project_Login_Port,Project_Login_User,Login_ISA_Key,cmds=execute_command)
if result is False:
print "Error 3:Execute command failed!"
if __name__ == '__main__':
main()
页:
[1]