SaltStack-job管理

一、salt执行结果默认返回给master端

1、job cache

存放位置

# Directory to store job and cache data:
# This directory may contain sensitive data and should be protected accordingly.
#
#cachedir: /var/cache/salt/master

# Set the number of hours to keep old job information in the job cache:
#keep_jobs: 24

# The number of seconds to wait when the client is requesting information
# about running jobs.
#gather_job_timeout: 10

2、将cache存入数据库

（1）安装数据库连接模块

安装连接mysql的模块MySQL-python
yum install -y MySQL-python

（2）配置数据库连接

在master上配置连接

直接在master的配置文件后面追加内容
vim /etc/salt/master

master_job_cache: mysql
mysql.host: '192.168.56.11'
mysql.user: 'salt'
mysql.pass: '123456'
mysql.db: 'salt'
mysql.port: 3306

（3）重启salt-master

systemctl restart master

（4）验证是否写入数据库

执行如下命令
[root@linux-node1 /srv/salt/prod/bbs]# salt '*' cmd.run 'whoami'
linux-node2.example.com:
    root
linux-node1.example.com:
    root

登录数据库
mysql -h 192.168.56.11 -usalt -p123456
MariaDB [(none)]> use salt;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A

*************************** 9. row ***************************
       fun: cmd.run
       jid: 20161109091010973295
    return: "root"
        id: linux-node2.example.com
   success: 1
  full_ret: {"fun_args": ["whoami"], "jid": "20161109091010973295", "return": "root", "retcode": 0, "success": true, "cmd": "_return", "_stamp": "2016-11-09T01:10:11.064745", "fun": "cmd.run", "id": "linux-node2.example.com"}
alter_time: 2016-11-09 09:10:11
*************************** 10. row ***************************
       fun: cmd.run
       jid: 20161109091010973295
    return: "root"
        id: linux-node1.example.com
   success: 1
  full_ret: {"fun_args": ["whoami"], "jid": "20161109091010973295", "return": "root", "retcode": 0, "success": true, "cmd": "_return", "_stamp": "2016-11-09T01:10:11.146238", "fun": "cmd.run", "id": "linux-node1.example.com"}
alter_time: 2016-11-09 09:10:11
10 rows in set (0.00 sec)

3、job查看

先执行一个命令，比如

salt '*' cmd.run 'ping www.baidu.com'

在执行job查看命令

[root@linux-node1 ~]# salt '*' saltutil.running
linux-node2.example.com:
    |_
      ----------
      arg:
          - ping www.baidu.com
      fun:
          cmd.run
      jid:
          20161109091517283293
      pid:
          6049
      ret:
      tgt:
          *
      tgt_type:
          glob
      user:
          root
linux-node1.example.com:
    |_
      ----------
      arg:
          - ping www.baidu.com
      fun:
          cmd.run
      jid:
          20161109091517283293
      pid:
          6269
      ret:
      tgt:
          *
      tgt_type:
          glob
      user:
          root

停止job，可以使用如下方法

[root@linux-node1 ~]# salt '*' saltutil.kill_job 20161109091517283293
linux-node2.example.com:
    Signal 9 sent to job 20161109091517283293 at pid 6049
linux-node1.example.com:
    Signal 9 sent to job 20161109091517283293 at pid 6269
[root@linux-node1 ~]# salt '*' saltutil.running
linux-node2.example.com:
linux-node1.example.com:

4、master端cache

存放位置

[root@linux-node1 /var/cache/salt/master]# ls
file_lists  jobs  minions  proc  queues  roots  syndics  tokens
[root@linux-node1 /var/cache/salt/master]# pwd
/var/cache/salt/master
[root@linux-node1 /var/cache/salt/master]# tree
.
├── file_lists
│   └── roots
│       ├── base.p
│       └── prod.p
├── jobs
│   ├── 6c
│   │   └── 9f646ec75df0bd0ec29760ef0dee7a
│   │       ├── jid
│   │       └── linux-node1.example.com
│   │           └── return.p
│   ├── 90
│   │   └── d3646e58dd82e103973eb889af96d1
│   │       └── jid
│   ├── d4
│   │   └── 74a5b7f1ebf41c84c714d2ad8fda85
│   │       ├── jid
│   │       └── linux-node1.example.com
│   │           └── return.p
│   └── e3
│       └── d2ffbc8e72a923205126c07c9e1e55
│           ├── jid
│           └── linux-node1.example.com
│               └── return.p

二、jobs管理组件

一个方便管理jobs的系统：runners.jobs

列出job cache中的job
[root@linux-node1 /var/cache/salt/master]# salt-run jobs.list_jobs
[WARNING ] /usr/lib/python2.7/site-packages/salt/grains/core.py:1493: DeprecationWarning: The "osmajorrelease" will be a type of an integer.

20161109090923312794:
    ----------
    Arguments:
        - whoami
    Function:
        cmd.run
    StartTime:
        2016, Nov 09 09:09:23.312794
    Target:
        *
    Target-type:
        glob
    User:
        root

查看某个job的返回

[root@linux-node1 ~]# salt-run jobs.lookup_jid 20161109093137760714

linux-node1.example.com:
    PING www.a.shifen.com (119.75.218.70) 56(84) bytes of data.
    64 bytes from 119.75.218.70: icmp_seq=1 ttl=128 time=9.78 ms
    64 bytes from 119.75.218.70: icmp_seq=2 ttl=128 time=4.65 ms
    64 bytes from 119.75.218.70: icmp_seq=3 ttl=128 time=8.26 ms
    
    --- www.a.shifen.com ping statistics ---
    3 packets transmitted, 3 received, 0% packet loss, time 2010ms
    rtt min/avg/max/mdev = 4.657/7.569/9.786/2.150 ms

可以使用salt-run查看当前up和down的minion

[root@linux-node1 ~]# salt-run manage.status
down:
up:
    - linux-node1.example.com
    - linux-node2.example.com