saltstack部署returner [三]

yinl_li

　　saltstack部署returner
　　感悟:大家有没有遇到过当salt的minion太多时候，每次查看执行结果都要看很久，而且屏幕都占满了。也不方便查看是否执行成功。这个时候saltsack的returner功能上场了。我们可以把执行的命令结果存入数据库，通过数据库查看就很方便了。不过在安装测试中遇到很多问题。这里要感谢成都运维群的运维@安，他帮我查到为什么不能写入数据库的原因，在这里感谢他。
　　saltstack执行结果写入到mysql数据库配置
　　1.建数据库及表
　　#假设我们的数据库服务器为192.168.3.206,也可以在master上面安装一个数据库。
　　进入192.168.3.206数据库上面操作如下:
　　#建数据库
　　CREATE DATABASE  salt
　　DEFAULT CHARACTER SET utf8
　　DEFAULT COLLATE utf8_general_ci;
　　#打开数据库
　　use salt
　　#新建表结构
　　CREATE TABLE `salt_returns` (
　　`fun` varchar(50) NOT NULL,
　　`start_time` varchar(255) NOT NULL,
　　`jid` varchar(255) NOT NULL,
　　`return` mediumtext NOT NULL,
　　`minion_id` varchar(255) NOT NULL,
　　`order` varchar(255) NOT NULL,
　　`success` varchar(10) NOT NULL,
　　KEY `minion_id` (`minion_id`),
　　KEY `jid` (`jid`),
　　KEY `fun` (`fun`),
　　KEY `jid_success` (`jid`,`success`)
　　) ENGINE=InnoDB DEFAULT CHARSET=utf8;
　　#建权限
　　use mysql

　　GRANT ALL PRIVILEGES ON salt.* TO 'salt'@'192.168.3.%'>　　#这里只允许192.168.3网段连接数据库.用户为salt密码为salt_pass
　　2.安装MySQLdb模块
　　在minion上面操作如下:
　　注意:我的所有minion都是用的/usr/bin/python2.6 /usr/bin/salt-minion -d 这种方式启动的.
　　他是执行的/usr/bin/python2.6这个python文件,系统本身还存在一个python 2.4.3版本,要想
　　minion操作数据库.我们以后执行python的时候,全部要用/usr/bin/python2.6这个命令.不然会报错.
　　2.1.下载setuptools
　　http://pypi.python.org/packages/source/s/setuptools/setuptools-0.6c8.tar.gz
　　cd /root/soft
　　tar -zxf setuptools-0.6c8.tar.gz
　　cd setuptools-0.6c8
　　/usr/bin/python2.6 setup.py build
　　/usr/bin/python2.6 setup.py install
　　2.2.下载:MySQL-python
　　yum -y install mysql-devel libxml2 libxml2-dev libxslt* zlib gcc openssl python26-mysqldb python26-devel  #安装这些依赖包,不然要报错.
　　cd /root/soft
　　unzip MySQL-python-1.2.5.zip
　　cd MySQL-python-1.2.5
　　/usr/bin/python2.6 setup.py build
　　/usr/bin/python2.6 setup.py install
　　2.3.测试模块
　　cd /usr/local
　　/usr/bin/python2.6 -c 'import MySQLdb'
　　#如果没有报错表示正常.测试以前一定不要在MySQL- python-1.2.5这个目录测试,会有冲突的.
　　可以cd到其他目录测试.我这边测试以前是先cd /usr/local目录.
　　3.mysql_return模块编写
　　在master上面操作如下:
　　3.1编写mysql_return.py文件
　　vim /srv/salt/_returners/mysql_return.py
import MySQLdb,json,time　　
__virtualname__ = "mysql_return"
　　
def __virtual__():
　　
        return __virtualname__
　　
def returner(ret):
　　
        MysqlConn=MySQLdb.connect(host='192.168.3.206',user='salt',passwd='salt_pass',db='salt',charset="utf8")
　　
        MysqlCursor=MysqlConn.cursor()
　　
        SaltSql="insert into salt_returns values (%s,%s,%s,%s,%s,%s,%s)" % (str(json.dumps(ret['fun'])),"'"+str(time.strftime("%F %T"))+"'",str(json.dumps(ret['jid'])),"'"+str(json.dumps(ret['return']))+"'",str(json.dumps(ret['id'])),"'"+str(json.dumps(ret['fun_args']))+"'","'"+str(json.dumps(ret['success']))+"'")
　　
        try:
　　
                MysqlCursor.execute(SaltSql)
　　
        except:
　　
                SaltSql="insert into salt_returns values (%s,%s,%s,%s,%s,%s,%s)" % (str("false"),str("false"),str("false"),"'"+str(time.strftime("%F %T"))+"'",str("false"),str("false"),"'"+str("false")+"'")
　　
                MysqlCursor.execute(SaltSql)
　　
        MysqlConn.commit()
　　
        MysqlCursor.close()
　　
        MysqlConn.close()
　　#备注:这里的IP是数据库IP及连接salt的用户和密码
　　3.2同步returner到所有minion机器
　　salt '*' saltutil.sync_returners
　　web100:
　　- returners.mysql_return
　　web101:
　　- returners.mysql_return                       #看到左边信息说明模块同步成功
　　3.3执行命令查看结果
　　salt "*" cmd.run "hostname" --return=mysql_return
　　3.4进入192.168.3.206数据库上面操作如下:
　　mysql -u root -p123
　　mysql> use salt
　　mysql> select * from salt_returns;
　　+-----------+---------------------+----------------------+--------------+-----------+--------------+---------+
　　| fun       | start_time          | jid                  | return       | minion_id | order        | success |
　　+-----------+---------------------+----------------------+--------------+-----------+--------------+---------+
　　| cmd.run   | 2014-07-25 10:37:29 | 20140725103729630158 | "srv100.com" | web100    | ["hostname"] | true    |
　　| cmd.run   | 2014-07-25 10:37:29 | 20140725103729630158 | "srv101.com" | web101    | ["hostname"] | true    |注:看到数据库里面有记录,说明执行日志写入数据库成功.