yinl_li 发表于 2018-8-1 10:21:20

saltstack部署returner [三]

  saltstack部署returner
  感悟:大家有没有遇到过当salt的minion太多时候,每次查看执行结果都要看很久,而且屏幕都占满了。也不方便查看是否执行成功。这个时候saltsack的returner功能上场了。我们可以把执行的命令结果存入数据库,通过数据库查看就很方便了。不过在安装测试中遇到很多问题。这里要感谢成都运维群的运维@安,他帮我查到为什么不能写入数据库的原因,在这里感谢他。
  saltstack执行结果写入到mysql数据库配置
  1.建数据库及表
  #假设我们的数据库服务器为192.168.3.206,也可以在master上面安装一个数据库。
  进入192.168.3.206数据库上面操作如下:
  #建数据库
  CREATE DATABASEsalt
  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    |注:看到数据库里面有记录,说明执行日志写入数据库成功.
页: [1]
查看完整版本: saltstack部署returner [三]