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.%' IDENTIFIED BY 'salt_pass';

#这里只允许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.pyimport 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    |注:看到数据库里面有记录,说明执行日志写入数据库成功.