不通用版(从SVN取版本,通过MAVEN生成JAVA包,通过SALTSTACK传送到远程服务器并自动重启TOMCAT服务)PYTHON代码

简介:

从昨晚写到今天啊,

第一版测试成功了。

PHP和JAVA的更新相对来说,PHP的自动化更新是简单多啦~~

当然,这只是运维工作当中的一环~~

复制代码
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import os,sys,commands,subprocess  
import re,time,logging
from optparse import OptionParser

#启动日志模块
logging.basicConfig(level=logging.INFO,
                format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
                datefmt='%a, %d %b %Y %H:%M:%S',
                filename='updateSVN.log',
                filemode='a')
#将输入的参数与相应的配置文件匹配,并形成特殊字典,方便后续取值
def get_svn_list(name, ip, version):
    svn_update = {}
    for line in open("data_svn_src_java"):
    line_item = line.strip("\n").split("|")
    if ip == line_item[0] and name == line_item[1]:
        line_item = line.strip("\n").split("|")
        svn_update["salt_minion_ip"] = line_item[0]
        svn_update["svn_name"] = line_item[1]
        svn_update["salt_master_dir"] = "/srv/salt/%s/" % line_item[0]
        svn_update["server_dir"] = line_item[2]
        svn_update["svn_dir"] = line_item[3]
        svn_update["package_name"] = line_item[4]
        svn_update["svn_version"] = version
    if len(svn_update) != 7:
    error_output("database have none item at your xargs.")
    return svn_update

#统一错误输出,红色文字提示
def error_output(error_str):
    print '\033[0;31;40m'
    print error_str + "<br>"
    print '\033[0m'
    sys.exit(1)

#统一调用执行系统命令,并产生相应输出及日志记录
def exec_cmd(cmd):
    str_now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
    (status,output) = commands.getstatusoutput(cmd)
    try:
    if int(status) == 0:
        print "%s   %s  is ---OK!<br>" % (str_now, cmd)
        logging.info(cmd + " ---is OK!")
        return output
    else:
        logging.info(cmd + " cant't finish...")
        print "%s   %s  can't finish...<br>" % (str_now, cmd)
        sys.exit(1)
    except:
    logging.info(cmd + " is Wrong")
    print "%s   %s  --- is Wrong<br>" % (str_now, cmd)
    sys.exit(1)

#在真正应用SALTSTACK之前,先测试是否正常连接
def salt_minion_test(salt_minion_ip):
    if "True" not  in exec_cmd("salt '%s' test.ping" % salt_minion_ip):
        error_output("salt minion %s is not active,please restart this minion and execute is again. " % salt_minion_ip)
    else:
    print "salt minion ip %s is ok.<br>" % salt_minion_ip
#从SVN相应目录里取出文件,存放在SALTSTACK的相应目录里(以IP作为目录存放位置)
def get_svn_file(svn_dir, svn_version, salt_master_dir):
    exec_cmd("rm -rf %s" % salt_master_dir)
    exec_cmd("mkdir -p %s" % salt_master_dir)
    svnLog_cmd ="svn co  %s %s  --username cheng168 --password chengcheng -r %s" % (svn_dir, salt_master_dir, svn_version)
    output = exec_cmd(svnLog_cmd)
    if svn_version not  in output:
        error_output("svn version is Wrong<br>")
        sys.exit(1)
#用MAVEN生成相应的JAR或WAR包
def gen_package(salt_master_dir):
    mvn_cmd = "mvn clean install -Dmaven.test.skip=true -Pprod -f %spom.xml" % (salt_master_dir)
    exec_cmd(mvn_cmd)

#由于数据频道特殊,脚本会在解压之后生成一个备份。
def update_back():
    print "back_pass"

#以下几个函数是为了区别consumer和provider的更新,主要是执行相关系统调用
def shutdown_consumer_tomcat(salt_minion_ip, server_dir):
    tomcat_dir = '/'.join(server_dir.split('/')[:-3])
    shutdown_A_cmd  = "salt '%s' cmd.run 'su - tomcat -c %s/bin/shutdown.sh'" % (salt_minion_ip, tomcat_dir)
    exec_cmd(shutdown_A_cmd)
    time.sleep(2)
    shutdown_B_cmd = """salt '%s' cmd.run "ps aufx|grep tomcat|grep %s/endorsed|grep -v grep|awk '{print $2}'|xargs kill -9" """% (salt_minion_ip, tomcat_dir)
    exec_cmd(shutdown_B_cmd)

def shutdown_provider_java(salt_minion_ip, package_name):
    shutdown_jar_cmd = """salt '%s' cmd.run "ps aufx|grep %s|grep -v grep|awk '{print $2}'|xargs kill -9" """ % (salt_minion_ip, package_name)
    exec_cmd(shutdown_jar_cmd)

def startup_consumer_tomcat(salt_minion_ip, server_dir):
    tomcat_dir = '/'.join(server_dir.split('/')[:-3])
    startup_cmd = "salt '%s' cmd.run 'su - tomcat -c %s/bin/startup.sh'" % (salt_minion_ip, tomcat_dir)
    #exec_cmd(startup_cmd)
    #此处不能再调用exec_cmd,因为不能及时获取返回值,再开一个子进程,就流畅多啦。。
    subprocess.Popen(startup_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)

def startup_provider_java(salt_minion_ip, server_dir, package_name):
    #此处太过技巧化,希望以后能写成更好理解的,三引号的使用,切换用户帐号,后台执行服务器命令都全了。
    startup_cmd = """salt '%s' cmd.run 'su - tomcat -c "java -jar %s%s &"'""" % (salt_minion_ip, server_dir, package_name)
    print startup_cmd
    #exec_cmd(startup_cmd)
    subprocess.Popen(startup_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)

def update_consumer_package(salt_minion_ip, server_dir, package_name):
    #几个变量主要是为了精简配置文件,将备份放在合适的目录
    package_dir = ''.join(package_name.split('.')[0])
    tomcat_dir = '/'.join(server_dir.split('/')[:-3])
    salt_master_file = "salt://%s/target/%s" % (salt_minion_ip, package_name)
    salt_minion_file = server_dir + package_name
    back_minion_dir = tomcat_dir + "/backup/"
    update_package_cmd = "salt '%s' cp.get_file %s %s makedirs=True" % (salt_minion_ip, salt_master_file, salt_minion_file)
    exec_cmd(update_package_cmd)
    unzip_cmd = "salt '%s' cmd.run 'unzip %s%s -d %s'" % (salt_minion_ip, server_dir, package_name, server_dir)
    exec_cmd(unzip_cmd)
    chown_cmd = "salt '%s' cmd.run 'chown tomcat:tomcat %s'" % (salt_minion_ip, server_dir)
    exec_cmd(chown_cmd)
    #小峤要求解压后删除WAR文件,便于后期直接更新静态文件,我在此处正好将它备份起来
    mv_cmd = "salt '%s' cmd.run 'mv %s %s'" % (salt_minion_ip, salt_minion_file, back_minion_dir)
    exec_cmd(mv_cmd)

#因为DUBBO的CONSUMER消费者为WAR包,服务提供者为JAR包,所以启动,关闭,更新上传都分成了两套函数
def update_provider_package(salt_minion_ip, server_dir, package_name):
    salt_master_file = "salt://%s/target/%s" % (salt_minion_ip, package_name)
    salt_minion_file = server_dir + package_name
    update_package_cmd = "salt '%s' cp.get_file %s %s makedirs=True" % (salt_minion_ip, salt_master_file, salt_minion_file)
    exec_cmd(update_package_cmd)
    cp_cmd = "salt '%s' cmd.run 'cp %s %s.bak'" % (salt_minion_ip, salt_minion_file, salt_minion_file)
    exec_cmd(cp_cmd)
    chown_cmd = "salt '%s' cmd.run 'chown tomcat:tomcat %s*'" % (salt_minion_ip, server_dir)
    exec_cmd(chown_cmd)

def main(name, ip, version):
    svn_update = get_svn_list(name, ip, version)
    salt_minion_test(svn_update["salt_minion_ip"])
    get_svn_file(svn_update["svn_dir"], svn_update["svn_version"], svn_update["salt_master_dir"])
    gen_package(svn_update["salt_master_dir"])
    update_back()
    #服务器和消费的前面操作都相同,但在此后,要分路径判断执行相应的操作
    if svn_update["package_name"] == "consumer.war" :
        shutdown_consumer_tomcat(svn_update["salt_minion_ip"], svn_update["server_dir"])
        update_consumer_package(svn_update["salt_minion_ip"], svn_update["server_dir"], svn_update["package_name"])
        startup_consumer_tomcat(svn_update["salt_minion_ip"], svn_update["server_dir"])
    if svn_update["package_name"] == "provider.jar" :
    shutdown_provider_java(svn_update["salt_minion_ip"], svn_update["package_name"])
    update_provider_package(svn_update["salt_minion_ip"], svn_update["server_dir"], svn_update["package_name"])
    startup_provider_java(svn_update["salt_minion_ip"], svn_update["server_dir"], svn_update["package_name"])
if __name__=="__main__":
    #输入参数判断,如有输入不完,及早提示并退出
    usage = "usage: %prog [options] arg :./update.py -v 12292 -n bbs -i 192.168.11.75"
    parser = OptionParser(usage)
    parser.add_option("-v", "--version", dest="version", help="input the version(Sample: 15435...).")
    parser.add_option("-n", "--name", dest="name", help="input the svn name(consumer|provider)")
    parser.add_option("-i", "--ip", dest="ip", help="input the ip address(1.4.8.25|11.14.7.2)")
    (options, args) = parser.parse_args()
    version = options.version
    name = options.name
    ip = options.ip
    if version is None or name is None or ip is None :
        error_output("you must input all args: ./update_svn_shuju.py -i xx  -n xx -v xx")
    main(name, ip, version)
复制代码
目录
相关文章
|
5天前
|
Python
探索Python中的装饰器:简化代码,增强功能
【9月更文挑战第3天】在Python的世界里,装饰器是那些静悄悄站在角落、却能大大改变游戏规则的神奇工具。它们就像是给你的函数穿上一件隐形的超级英雄斗篷,让函数拥有了超乎寻常的能力。本文将带领你一探究竟,看看如何通过几行简单的代码,就能让你的函数变得更加智能和强大。
|
2天前
|
缓存 测试技术 开发者
探索Python中的装饰器:简化你的代码之旅
【9月更文挑战第6天】本文将深入探讨Python中一个强大而神秘的特性——装饰器。我们将通过实际例子揭示装饰器的工作原理,并展示如何利用它们来简化和增强你的代码。无论你是初学者还是有经验的开发者,这篇文章都将为你打开一扇门,让你的代码更加优雅和高效。
|
5天前
|
Python
Python中的装饰器:简化你的代码
【9月更文挑战第3天】装饰器,这个听起来有些神秘的名词,实际上在Python中扮演着重要的角色。它们就像是你的代码的小助手,帮你自动完成一些重复性的工作,让你的代码更加简洁、易读。本文将通过一个简单的例子,带你走进装饰器的世界,看看它们是如何工作的。
|
5天前
|
测试技术 数据安全/隐私保护 Python
Python中的装饰器:简化你的代码
【9月更文挑战第3天】装饰器在Python中是一个非常强大的工具,它可以让我们在不改变原有函数定义的情况下,对函数进行扩展,增加额外的功能。本文将通过一个简单的例子,介绍如何在Python中使用装饰器,以及如何使用装饰器来简化我们的代码。
13 6
|
4天前
|
缓存 数据挖掘 Python
探索Python中的装饰器:简化代码,提高效率
【9月更文挑战第4天】在Python的世界里,装饰器是那些隐藏在幕后、默默发挥作用的英雄。它们以优雅的姿态简化我们的代码,提升程序的可读性和效率。本文将带你揭开装饰器的神秘面纱,通过实际案例展示其魅力所在,让你的编程之旅更加顺畅。
|
4天前
|
存储 Python
Python编程入门:从零开始的代码之旅
【9月更文挑战第4天】本文将带领初学者步入Python的世界,通过简明的语言和直观的例子,逐步揭示编程的乐趣。我们将一起构建基础的数据结构,探索控制语句的奥秘,并实现简单的函数。无论你是编程新手还是希望巩固基础,这篇文章都是你理想的起点。让我们开始吧,一步步将代码块搭建成思维的宫殿!
15 2
|
5天前
|
存储 设计模式 缓存
Python中的装饰器:简化代码,提高可读性
【9月更文挑战第3天】在Python编程中,装饰器是一种强大的工具,它允许我们修改或增强函数的行为,而无需更改其源代码。通过本文,您将了解装饰器的基本概念、如何创建和使用它们,以及它们如何帮助我们编写更简洁、更可读的代码。我们将以一个简单的示例开始,逐步深入到更复杂的应用场景,展示装饰器的灵活性和强大功能。无论您是初学者还是有经验的开发者,本文都将为您提供新的视角和技巧,让您的Python代码更加优雅和高效。
|
7天前
|
存储 缓存 分布式计算
|
8天前
|
Python
探索Python装饰器:简化代码,提升效率
【8月更文挑战第31天】装饰器在Python中是一种强大的工具,它允许我们在不修改函数代码的情况下增加额外的功能。本文将通过实际例子和简单易懂的语言,带你了解什么是装饰器、如何创建和使用它们,以及装饰器如何帮助我们编写更加简洁高效的代码。我们将从基础开始,逐步深入到装饰器的高级应用,让你轻松掌握这一实用的编程技巧。
|
8天前
|
算法 Python
揭秘Python编程之美:从代码到艺术的转变
【9月更文挑战第1天】 在这篇文章中,我们将一起探索如何将看似枯燥的Python编程代码转变为一门充满创造性和美感的艺术。通过深入浅出的解释、生动的例子和实用的技巧,你将学会如何编写更加优雅、高效且易于理解的Python代码,从而提升你的编程技能并享受编程的乐趣。
13 2