febric的使用

from fabric.api import *
from fabric.colors import *
from fabric.tasks import execute
'''
env.hosts = ['192.468.4.50','192.168.4.51']
env.user = 'root'
env.port = 22
env.password = '123456'
env.passwords = {
    'root@192.168.4.50:22':'123456',
    'root@192.168.4.51:22':'123456',
}
'''


env.hosts = [
    'root@192.168.4.50:22',
    'root@192.168.4.51:22',
    'root@192.168.4.52:22',
    'root@192.168.4.53:22',
    'root@192.168.4.54:22',
    'root@192.168.4.55:22',
    'root@192.168.4.56:22',
    'root@192.168.4.57:22',
    'root@192.168.4.58:22',
    ]
env.password = '123456'


@runs_once
def xxx():
    cmd = prompt('请输入要执行的命令：')
    run(cmd)


# 本地执行命令
@runs_once
def local_cmd(cmd, dir=None):
    if dir == None:
        dir ='/root'
    with settings(hide('everything'), warn_only=True):
        with lcd(dir):                                          # 本地切换目录
            result = local(cmd)                                 # 本地执行命令
            print(green(result))

# 远程执行命令
def remote_cmd(cmd, dir=None):
    if dir == None:
        dir = '/root'
    with settings(hide('everything'), warn_only=True):
        with cd(dir):                                           # 远程切换目录
            result= run(cmd)                                    # 远程执行命令
            print(green(result))

# 查看端口信息
def port_info(port):
    cmd = "ss -autnlp | grep {}".format(port)
    with settings(hide('everything'), warn_only=True):
        result = run(cmd)
        print(green(result))



# 安装软件
def install_soft(soft):
    cmd = "yum -y install %s"%soft
    with settings(hide('everything'), warn_only=True):
        run(cmd)
        cmd = "rpm -qa | grep %s"%soft
        if cmd:
            print(green('安装成功'))

# 重启服务
def restart(service):
    cmd = "systemctl restart {}".format(service)
    with settings(hide('everything'), warn_only=True):
        result = run(cmd)
        print(green(result))

# 停止服务
def stop(service):
    cmd = "systemctl stop {}".format(service)
    with settings(hide('everything'), warn_only=True):
        result = run(cmd)
        print(green(result))

# 查看服务状态
def status(service):
    cmd = "systemctl status {}".format(service)
    with settings(hide('everything'), warn_only=True):
        result = run(cmd)
        print(green(result))
http://127.0.0.1:8000/
# 上传文件/压缩文件解压
def upload(src, tar=None):
    if tar == None:
        tar = src
    with settings(hide('everything'), warn_only=True):
        put(src, tar)
        print(green('upload successful'))
        print(tar[-3:])
        if tar[-3:] == ".gz":
            cmd = "tar -xf %s" % tar
            run(cmd)


# 下载文件
def download(src, tar=None):
    if tar == None:
        tar = src
    with settings(hide('everything'), warn_only=True):
        get(src, tar)
        print(green('download successful'))




#if __name__ == '__main__':
#   execute(xxx)
# fab -f fabfile.py update
# fab -f fabfile.py port_status:80

from fabric.api import *



env.user = 'root'
env.hosts = [
    '192.168.4.50',
    '192.168.4.51',
]
env.password = '123456'

@runs_once                                  # 只执行一次
@task
def local_update(dir):
    with lcd(dir):                          # 切换到本地某目录下
        local("git add -A")
        local("git commit -m update")
        local("git pull origin master")
        local("git push origin master")

@task
def remote_update(dir):
    with cd(dir):                           # 切换到远程某目录
        run("git checkout")
        run("git pull origin master")


@task
def deploy():
    local_update()
    remote_update()

from fabric.api import *
from fabric.context_managers import *
from fabric.contrib.console import confirm

env.user = 'root'
env.gateway = '192.168.1.23'   #定义堡垒机IP，作为文件上传、执行的中转设置
env.hosts = ['192.168.1.21','192.168.1.22']
env.passwords = {
    'root@192.168.1.21:22':'123456',
    'root@192.168.1.22:22':'abcdef',
    'root@192.168.1.23:22':'123abc',  #堡垒机账号信息
}

lpackpath = '/home/install/lnmp.tar.gz'   #本地安装包路径
rpackpath = '/tmp/install'    #远程安装包路径


@task
def put_task():  #上传文件
    run('mkdir -p /tmp/install')
    #默认情况下，当命令执行失败时，Fabric会停止执行后续命令。有时，我们允许忽略失败的命令继续执行，比如run(‘rm /tmp/abc')在文件不存在的时候有可能失败，这时可以用with settings(warn_only=True):执行命令，这样Fabric只会打出警告信息而不会中断执行。
    with settings(warn_only=True):
        result = put(lpackpath,rpackpath)   #上传
    if result.failed and not confirm('put file failed,Continue[Y/N]?'):
        abort('Aborting file put task!')

@task
def run_task():   #安装
    with cd('/tmp/install'):
        run('tar -zxvf lnmp.tar.gz')
        with cd('lnmp/'):    #使用with继承/tmp/install目录位置状态
            run('./centos.sh')


@task
def go():   #上传、安装组合命令
    put_task()
    run_task()