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的配置文件后面追加内容
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'

[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

[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管理组件

列出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

[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

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