saltstack（十二）job管理

hgjgh

　　前一篇总结过mine函数，有自动调度的功能。不过那个针对命令行，函数。应用范围较少。
　　这一篇总结一下salt里面的job管理。
　　官网描述mark
　　http://docs.saltstack.cn/topics/jobs/index.html#scheduling-jobs
　　如果把salt看成一个操作系统的话，job这东西差不多就相当于进程吧。
　　OK，先看一下minion端。minion的/var/cache/salt/minion/proc这个目录。存放着正在运行job
　　job运行完毕，就没了。
root@salt-minion:~# ls /var/cache/salt/minion/proc/　　
20140625195131612337
　　
root@salt-minion:~# ls /var/cache/salt/minion/proc/
　　
root@salt-minion:~#
　　master的job都存放在/var/cache/salt/master下面
root@salt-master:~# ls /var/cache/salt/master/jobs/　　master端的jobs，默认保存时间为24小时
root@salt-master:~# grep "keep_jobs" /etc/salt/master　　
#keep_jobs: 24
　　
root@salt-master:~#
　　查看正在运行的任务
root@salt-master:~# salt-run jobs.active　　
'20140625200124690176':
　　
  Arguments:
　　
  - /etc/init.d/mysql restart
　　
  Function: cmd.run
　　
  Returned:
　　
  - jid
　　
  Running: []
　　
  Target: '*'
　　
  Target-type: glob
　　
  User: root
　　
root@salt-master:~#
　　查看所有的历史任务，当然，这个历史任务是过去24小时内的。太多了，不好显示，我这里选取最后两个任务。
root@salt-master:~# salt-run jobs.list_jobs | tail  -n 16　　
'20140625200248729269':
　　
  Arguments:
　　
  - /bin/ls /home
　　
  Function: cmd.run
　　
  StartTime: 2014, Jun 25 20:02:48.729269
　　
  Target: '*'
　　
  Target-type: glob
　　
  User: root
　　
'20140625200258757661':
　　
  Arguments:
　　
  - /bin/ls /home
　　
  Function: cmd.run
　　
  StartTime: 2014, Jun 25 20:02:58.757661
　　
  Target: '*'
　　
  Target-type: glob
　　
  User: root
　　
root@salt-master:~#
　　查看某个任务的执行结果。
root@salt-master:~# salt-run jobs.lookup_jid 20140625200258757661　　
salt-minion:
　　
    lixc
　　
    lost+found
　　
    salt-develop
　　
    salt-develop.zip
　　
root@salt-master:~#
　　好再看一下salt的任务调度功能。
　　我们在mininon上面可以周期执行函数，highstate等。
　　好，看一下。这个例子就安装官网来了
root@salt-master:~# cat /srv/salt/files/schedule.conf　　
schedule:
　　
  log-loadavg:
　　
    function: cmd.run
　　
    seconds: 10
　　
    args:
　　
      - 'ls /home >>/tmp/1.log'
　　
    kwargs:
　　
    stateful: False
　　
    shell: True
　　

　　
  uptime:
　　
    function: status.uptime
　　
      seconds: 60
　　
      returner: mysql
　　
root@salt-master:~#
　　拷贝过去
root@salt-master:~# salt-cp  '*' /srv/salt/files/schedule.conf  /etc/salt/minion.d/　　
{'salt-minion': {'/etc/salt/minion.d/schedule.conf': True}}
　　检查一下，拷贝过去了没。
root@salt-master:~# salt '*'  cmd.run  'ls /etc/salt/minion.d/schedule.conf'　　
salt-minion:
　　
    /etc/salt/minion.d/schedule.conf
　　
root@salt-master:~#
　　拷贝过去了。重启一下minion
root@salt-master:~# salt '*'  service.restart salt-minion　　
salt-minion:
　　
    True
　　
root@salt-master:~#
　　看一下文件生成了没？
root@salt-master:~# salt '*'  cmd.run  'cat /tmp/1.log'　　
salt-minion:
　　
    lixc
　　
    lost+found
　　
    salt-develop
　　
    salt-develop.zip
　　
    lixc
　　
    lost+found
　　
    salt-develop
　　
    salt-develop.zip
　　已经生成了，并且已经执行两次，楼主是每10秒执行一次。
　　好，再看一下mysql里面生成数据了没。
root@salt-master:~# mysql -h10.240.161.98 -uroot -p"123456" -e "select * from \　　
> salt.salt_returns order by alter_time limit 1\G"
　　
*************************** 1. row ***************************
　　
       fun: cmd.run
　　
       jid: 20140625105655939721
　　
    return: 1
　　
123
　　
dec1.py
　　
        id: salt-minion
　　
   success: True
　　
  full_ret: {"fun_args": ["ls"], "jid": "20140625105655939721", "return": "1
　　
123
　　
dec1.py", "retcode": 0, "success": true, "fun": "cmd.run", "id": "salt-minion"}
　　
alter_time: 2014-06-25 10:56:55
　　
root@salt-master:~#
　　OK，minion端就这样了，当然还有一个highstate周期执行，第二篇写过了，就不旧时重提了。
　　看一下master端的一些schedule，master端runner可以周期执行。
　　看一下啊schedule.conf咋定义的
root@salt-master:~# cat >/etc/salt/master.d/schedule.conf <<EOF　　
> schedule:
　　
>   lsdir:
　　
>     function: lsdir.lsdir
　　
>     seconds: 20
　　
> EOF
　　楼主就用上一篇写的lsdir这个runner测试了。楼主修改了写，把信息写进了文件。
　　楼主测试了一下，schedule的方式下，函数好像不支持传参，楼主给函数设了默认参数。
root@salt-master:~# cat /srv/salt/_runners/lsdir.py　　
import salt.client
　　
import re
　　
def lsdir(directory='/home'):
　　
   match = re.findall(r'^(/)',directory)
　　
   if not match:
　　
       directory = "/%s" % directory
　　
   client = salt.client.LocalClient(__opts__['conf_file'])
　　
   ret  = client.cmd('*', 'cmd.run',['/bin/ls /home'],timeout=1)
　　
   for key,value in ret.items():
　　
       value_list = value.split('\n')
　　

　　
       file = open('/tmp/test.log','a+')
　　
       file.write(key+'\n')
　　
       for value in value_list:
　　
           file.write(' '*2+value+'\n')
　　
       file.close()
　　
root@salt-master:~#
　　OK，重启下master
root@salt-master:~# /etc/init.d/salt-master restart　　
[ ok ] Restarting salt master control daemon: salt-master.
　　
root@salt-master:~#
　　好，看一下结果。已执行了两次
　　root@salt-master:~# cat /tmp/test.log
　　salt-minion
　　lixc
　　lost+found
　　salt-develop
　　salt-develop.zip
　　salt-minion
　　lixc
　　lost+found
　　salt-develop
　　salt-develop.zip
　　root@salt-master:~#
　　OK，功能差不多就这些了。
　　最后别玩了把schedule干掉吧，不干掉，不停的生成数据，楼主是虚拟机，磁盘很小，迟早挂掉。
root@salt-master:~# cat < /etc/salt/master.d/schedule.conf　　
root@salt-master:~# salt '*' cmd.run 'echo  > /etc/salt/minion.d/schedule.conf'
　　
salt-minion:
　　

　　
root@salt-master:~# /etc/init.d/salt-master restart
　　
[ ok ] Restarting salt master control daemon: salt-master.
　　
root@salt-master:~# salt '*' service.restart salt-minion
　　
salt-minion:
　　
    True
　　
root@salt-master:~#
　　好了，下班回家了！