hgjgh 发表于 2018-8-1 10:36:23

saltstack(十二)job管理

  前一篇总结过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:~#
  好了,下班回家了!
页: [1]
查看完整版本: saltstack(十二)job管理