如何在SaltStack中检测Grain变更并触发Reactor？

核心问题点 #

1. 事件未触发：你监听的os_family_changed是自定义事件，但后端脚本更新Grain时，并没有主动向Salt事件总线发送这个事件，Reactor根本接不到触发信号。
2. Reactor逻辑错误：你的os_family_changed.sls里，old_os_family和grains['os_family']取的是同一个当前Grain值，条件判断永远不会成立，就算事件触发了也不会执行后续操作。

分步修复 #

1. 让Grain更新时自动发送事件 #

修改后端自动化脚本，在更新os_family Grain前后，获取新旧值并发送自定义事件到Salt总线。示例脚本如下：

# 获取旧的os_family值
OLD_OS=$(salt-call grains.get os_family --out=txt | awk '{print $2}')

# 执行Grain更新操作（替换成你的实际更新命令）
salt-call grains.setval os_family "NewOSFamily"

# 获取新的os_family值
NEW_OS=$(salt-call grains.get os_family --out=txt | awk '{print $2}')

# 发送自定义事件到Salt事件总线
salt-call event.send os_family_changed '{"id": "'$(hostname)'", "old_os_family": "'$OLD_OS'", "new_os_family": "'$NEW_OS'"}'

2. 修正Reactor状态文件逻辑 #

修改/srv/salt/reactor/os_family_changed.sls，从事件数据中读取新旧值进行判断，而不是重复读取当前Grain：

{% set old_os = data['old_os_family'] %}
{% set new_os = data['new_os_family'] %}
{% set minion_id = data['id'] %}

{% if old_os != new_os %}
trigger_state_on_grain_change:
  module.run:
    - name: state.apply
    - tgt: {{ minion_id }}
    - arg:
      - test_os_family_changed
{% endif %}

注意：state.apply的参数不需要带.sls后缀，Salt会自动识别状态文件。

3. 验证Reactor配置与权限 #

• 确保/etc/salt/master/reactor.conf配置正确，重启Salt Master服务：

  systemctl restart salt-master
  

• 检查/srv/salt/reactor/目录及文件的权限，确保Salt Master进程能读取：

  chown -R root:salt /srv/salt/reactor
  chmod -R 750 /srv/salt/reactor
  

4. 测试验证 #

1. 运行后端更新脚本，更新os_family Grain。
2. 查看Salt Master的事件日志，确认事件已接收：

   salt-run state.event pretty=True
   

3. 检查目标Minion的/tmp/test文件，确认是否有hi写入。

扩展场景：从EC2元数据读取Grain #

未来要从EC2元数据获取Grain，可以通过以下方式实现：

• 自定义Grain模块：在Minion的/srv/salt/_grains/目录下创建EC2元数据读取脚本（比如ec2_metadata.py），自动从EC2元数据服务拉取信息并作为Grain返回。
• 结合Reactor：当EC2元数据变化时（比如实例标签更新），可以通过CloudWatch Events或者自定义脚本监听变化，发送事件到Salt总线，触发Reactor执行对应状态。

内容的提问来源于stack exchange，提问作者john mich