Python Fabric 模块 介绍及简单应用

secce

引用时使用Python修饰符的形式进行,角色修饰符下面的任务函数为其作用域,　　
下面来看一个示例:
　　

　　

　　
env.roledefs = {
　　
    'webservers': ['192.168.1.21', '192.168.1.22', '192.168.1.23','192.168.1.24'],
　　
    'dbservers': ['192.168.1.25', '192.168.1.26']
　　
}
　　
@roles('webservers')
　　
def webtask():
　　
    run('/etc/init.d/nginx start')
　　

　　
@roles('dbservers')
　　
def dbtask():
　　
    run('/etc/init.d/mysql start')
　　

　　
@roles ('webservers', 'dbservers')
　　
def pubclitask():
　　
    run('uptime')
　　

　　

　　
def deploy():
　　
    execute(webtask)
　　
    execute(dbtask)
　　
    execute(pubclitask)
　　

　　
####################################
　　
fab -p  xxx@2016  -f fa0.py -l
　　
fab -p  xxx@2016  -f fa0.py webtask
　　
fab -p  xxx@2016  -f fa0.py deploy
　　

　　

　　

　　
常用API
　　

　　
Fabric提供了一组简单但功能强大的fabric.api命令集,简单地调用
　　
这些API就能完成大部分应用场景需求。Fabric支持常用的方法及说明如下:
　　
·local,执行本地命令,如:local('uname-s');
　　
·lcd,切换本地目录,如:lcd('/home');
　　
·cd,切换远程目录,如:cd('/data/logs');
　　

　　
·run,执行远程命令,如:run('free-m');
　　
·sudo,sudo方式执行远程命令,如:sudo('/etc/init.d/httpd start');
　　
·put,上传本地文件到远程主机,如:put('/home/user.info','/data/user.info');
　　
·get,从远程主机下载文件到本地,如:get('/data/user.info','/home/root.info');
　　
·prompt,获得用户输入信息,如:prompt('please input user password:');
　　
·confirm,获得提示信息确认,如:confirm("Tests failed.Continue[Y/N]？");
　　
·reboot,重启远程主机,如:reboot();
　　
·@task,函数修饰符,标识的函数为fab可调用的,非标记对fab不可见,纯业务逻辑;
　　
·@runs_once,函数修饰符,标识的函数只会执行一次,不受多台主机影响。
　　

　　

　　

　　
##文件名是fa.py
　　
#！/usr/bin/env python
　　
from fabric.api import *
　　
env.user='root'
　　
env.hosts=['192.168.23.140','192.168.23.141']
　　
env.password='wdzj@2016'
　　

　　
@runs_once #查看本地系统信息,当有多台主机时只运行一次
　　
def local_task(): #本地任务函数
　　
    local("uname -a")
　　
def remote_task():
　　
    with cd("/tmp"): #"with"的作用是让后面的表达式的语句继承当前状态,实现
　　
        run("ls -l") # "cd /data/logs && ls -l"的效果
　　

　　

　　

　　
##用法,执行下面命令
　　
#fab -p  wdzj@2016  -f fa.py local_task
　　
#fab -p  wdzj@2016  -f fa.py remote_task
　　

　　

　　

　　

　　
动态获取远程目录列表
　　
本示例使用“@task”修饰符标志入口函数go()对外部可见,
　　
配合“@runs_once”修饰符接收用户输入,最后调用worktask()任务函数
　　
实现远程命令执行,详细源码如下:
　　
【/home/test/fabric/simple2.py】
　　

　　
#！/usr/bin/env python
　　
from fabric.api import *
　　
env.user='root'
　　
env.hosts=['192.168.23.140','192.168.23.141']
　　
env.password='LKs934jh3'
　　
@runs_once #主机遍历过程中,只有第一台触发此函数
　　
def input_raw():
　　
    return prompt("please input directory name:",default="/home")
　　
def worktask(dirname):
　　
    run("ls -l "+dirname)
　　
@task #限定只有go函数对fab命令可见
　　
def go():
　　
    getdirname = input_raw()
　　
    worktask(getdirname)
　　

　　

　　
[root@localhost fabric]# fab -p  wdzj@2016 -f fa2.py -l
　　
Available commands:
　　

　　
    go
　　

　　

　　
[root@localhost fabric]# fab -p  wdzj@2016 -f fa2.py go
　　
。。。
　　
。。。
　　
。。。
　　

　　

　　

　　

　　
网关模式文件上传与执行
　　
本示例通过Fabric的env对象定义网关模式,即俗称的中转、堡垒机环境。
　　
定义格式为“env.gateway='192.168.1.23'”,其中IP“192.168.1.23”为堡垒机IP,
　　
再结合任务函数实现目标主机文件上传与
　　
执行的操作,详细源码如下:
　　

　　
【/home/test/fabric/simple3.py】
　　
from fabric.api import *
　　
from fabric.context_managers import *
　　
from fabric.contrib.console import confirm
　　

　　
env.user = 'root'
　　
env.gateway = '192.168.10.11'  # 定义堡垒机IP,作为文件上传、执行的中转设备
　　
env.hosts = ['192.168.23.140', '192.168.23.141']
　　
# 假如所有主机密码都不一样,可以通过env.passwords字典变量一一指定
　　
env.passwords = {
　　
    'root@192.168.1.21:22': 'LKs934jh3',
　　
    'root@192.168.1.22:22': 'LKs934jh3',
　　
    'root@192.168.1.23:22': 'UI7384hg6'  # 堡垒机账号信息
　　
}
　　
lpackpath = "/home/install/lnmp0.9.tar.gz"  # 本地安装包路径
　　
rpackpath = "/tmp/install"  # 远程安装包路径
　　

　　

　　
@task
　　
def put_task():
　　
    run("mkdir -p /tmp/install")
　　
    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():  # 执行远程命令,安装lnmp环境
　　
    with cd("/tmp/install"):
　　
        run("tar -zxvf lnmp0.9.tar.gz")
　　
    with cd("lnmp0.9/"):  # 使用with继续继承/tmp/install目录位置状态
　　
        run("./centos.sh")
　　

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

　　

　　
示例通过简单的配置env.gateway='192.168.1.23'就可以轻松实现堡垒机环境的文件上传及执行,
　　
相比paramiko的实现方法简洁了很多,编写的任务函数完全不用考虑堡垒机环境,
　　
配置env.gateway即可。