正文
saltstack 动态pillar实现
小程序：扫一扫查出行【扫一扫了解最新限行尾号】
复制小程序
简介
pillar支持的数据存储方式有很多，mysql, mogo,json等。本篇介绍关于http存储方式。
首先简要说明整个流程：salt-master会去一个指定http发送get请求获取一个json串，然后将json存储为pillar。获取json时是根据salt-minon的minion_id 去获取，也就说每个minion_id获取到的json是不同的，这样http页面就应该是一个动态页面。例如http:/test.com/pillar/minion_id；不同的minion_id获取不同的json串。
实现过程
（1）HTTP
首先要建立HTTP服务，方法很多，这里的关键是提供一个动态url，salt通过不同的minion_id获取对应要存储的pillar值。
# 动态url获取内容，需要达到下面的效果, node1和node2是不同的minion_id
访问 http://192.168.1.12:8088/pillar/node1
获取： ' {"serverid":"1001","mysql_port":"3306"}'
访问 http://192.168.1.12:8088/pillar/node2
获取： ' {"serverid":"1002","mysql_port":"3306"}'
（2）salt 源码修改
写了个高大上的名字，其实就是添加一个Python脚本。。。脚本目录是在salt安装在python的site-packages目录里。找不到就find / -name salt ；
# cd /usr/local/lib/python3.6/site-packages/salt/pillar/ # 这个目录下是pillar的各种ext_pillar方法
# vim ops.py # 创建一个python脚本，名字随意取，但一定要唯一，名字之后会用到
#!/usr/bin/env python
# -*- coding:utf-8 -*-
# author : wangyongcunimport logging
import requests
import jsonlog = logging.getLogger(__name__)def ext_pillar(minion_id, pillar, api):
pillar_url = api + "/" + minion_id # 不同minion将访问不同的url
log.warning("Querying SOPS system Pillar of %s" % (minion_id, )) # 自己加的一条日志，可忽略
try:
ret = requests.get(url=pillar_url) # 向url发送get请求，这个方法需要requests模块，若没有需要安装，在master安装就可以
r = ret.text # get获取到的结果
if r:
result = json.loads(r) # 将获取的json字符串转化为字典类型
else: # 如果获取的json为空
result = {}
except Exception as e: # 这个异常处理，一般情况都是无法连接url获取到内容，记录个日志
log.exception(
"Query SOPS system failed! Error: [%s] :%s" % (minion_id,e, )
)
return {}
return result # 返回字典格式的数据
（3）修改salt-master 配置文件
# vim /etc/salt/master
# 注意格式空格
ext_pillar:
- sops: # 这个是上面添加的py文件名称
api: http://192.168.1.12:8088/pillar/
（4）重启master
# 重启
systemctl stop salt-master
systemctl start salt-master
# 刷新pillar
salt '*' saltutil.refresh_pillar
# 查看一下
[root@aliyuntest ~]# salt '*' pillar.items
node1:
----------
mysql_port:
3306
serverid:
1001
node2:
----------
mysql_port:
3306
serverid:
1002
