如何使用Ansible带延迟执行数据库ALTER语句？

完全可以用Ansible的数据库专用模块+循环+暂停功能实现，既能逐条执行带延迟，又能自动检测执行结果（比如认证失败、SQL语法错误都会直接触发任务失败，无需额外判断），比之前的shell脚本方案更可靠。

1. 读取ALTER语句文件 #

假设你生成的ALTER语句文件位于远程数据库节点的/tmp/alter_commands.sql路径，先用slurp模块读取并拆分语句：

- name: 读取ALTER语句文件
  slurp:
    src: /tmp/alter_commands.sql
  register: alter_commands_raw

- name: 拆分语句为列表（过滤空行）
  set_fact:
    alter_commands: "{{ (alter_commands_raw.content | b64decode).splitlines() | reject('equalto', '') | list }}"

如果文件在Ansible控制节点，替换为lookup模块读取：

- name: 读取控制节点上的ALTER语句文件
  set_fact:
    alter_commands: "{{ lookup('file', './alter_commands.sql').splitlines() | reject('equalto', '') | list }}"

2. 逐条执行并添加延迟 #

使用对应数据库的专用模块（以PostgreSQL为例，MySQL用mysql_query），配合loop遍历语句，每次执行后用pause模块等待2分钟：

- name: 逐条执行ALTER语句，间隔2分钟
  postgresql_query:
    db: my_database
    login_user: db_user
    login_password: "{{ db_password }}"  # 建议用Ansible Vault加密存储密码
    login_host: "{{ db_host | default('localhost') }}"
    query: "{{ item }}"
  loop: "{{ alter_commands }}"
  pause:
    minutes: 2
  when: not ansible_loop.first  # 第一条语句执行前不添加延迟

核心优势说明 #

• 自动结果校验：数据库模块会捕获认证失败、SQL语法错误、权限不足等所有执行异常，直接标记任务失败并输出详细错误信息，无需手动判断退出码。
• 无需传输脚本：全程通过Ansible模块执行，不用复制shell脚本到远程节点，简化流程。
• 灵活控制延迟：通过pause模块精准控制间隔，可根据需求调整时长。

3. 可选：错误处理与日志记录 #

如果需要忽略特定错误或记录执行日志，可调整任务参数：

- name: 逐条执行ALTER语句（可选：忽略指定错误）
  postgresql_query:
    db: my_database
    login_user: db_user
    login_password: "{{ db_password }}"
    query: "{{ item }}"
  loop: "{{ alter_commands }}"
  register: exec_result
  failed_when: exec_result.failed and '预期可忽略的错误关键词' not in exec_result.msg
  pause:
    minutes: 2
  when: not ansible_loop.first
  ignore_errors: yes  # 仅在需要跳过失败继续执行时启用

完整示例Playbook #

---
- name: 带延迟执行数据库ALTER语句
  hosts: db_servers
  gather_facts: no
  vars:
    db_password: !vault |
          $ANSIBLE_VAULT;1.1;AES256
          # 此处为加密后的数据库密码
  tasks:
    - name: 读取远程节点上的ALTER语句文件
      slurp:
        src: /tmp/alter_commands.sql
      register: alter_commands_raw

    - name: 拆分语句为列表并过滤空行
      set_fact:
        alter_commands: "{{ (alter_commands_raw.content | b64decode).splitlines() | reject('equalto', '') | list }}"

    - name: 逐条执行ALTER语句，间隔2分钟
      postgresql_query:
        db: my_database
        login_user: db_user
        login_password: "{{ db_password }}"
        query: "{{ item }}"
      loop: "{{ alter_commands }}"
      pause:
        minutes: 2
      when: not ansible_loop.first

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