如何使用Ansible执行阻塞命令并在检测到指定输出后终止？

原生Ansible确实无法直接实现这个需求——因为即使是异步任务，也需要等任务执行完成后才能检查输出，没法实时监控输出并中途终止进程。但你可以通过两种方式实现：

一、用现有模块配合Shell脚本快速实现 #

不需要编写自定义模块，先在本地写一个监控脚本，用Ansible传到远程主机后执行：

示例Shell脚本（wait_for_output.sh） #

#!/bin/bash
# 启动目标阻塞命令，合并标准输出和错误输出
$1 | while read -r line; do
    echo "$line"
    # 检查当前行是否包含目标字符串
    if [[ "$line" == *"$2"* ]]; then
        # 终止目标命令的进程组，避免残留子进程
        pkill -P $$ $(basename "$1")
        exit 0
    fi
done

Ansible Playbook调用示例 #

- name: 复制监控脚本到远程主机
  copy:
    src: wait_for_output.sh
    dest: /tmp/wait_for_output.sh
    mode: 0755

- name: 执行阻塞命令并等待特定输出
  command: /tmp/wait_for_output.sh "your_blocking_command" "目标匹配字符串"

二、自定义Ansible模块实现 #

如果需要更优雅的集成，可以编写Python自定义模块，直接在Ansible中调用：

自定义模块代码（custom_wait_command.py） #

#!/usr/bin/python
import os
import subprocess
import signal
from ansible.module_utils.basic import AnsibleModule

def main():
    module = AnsibleModule(
        argument_spec=dict(
            command=dict(required=True, type='str'),
            match_string=dict(required=True, type='str')
        )
    )

    cmd = module.params['command']
    match_str = module.params['match_string']

    # 启动命令并捕获输出，创建进程组以便批量终止
    proc = subprocess.Popen(
        cmd,
        shell=True,
        stdout=subprocess.PIPE,
        stderr=subprocess.STDOUT,
        text=True,
        preexec_fn=os.setsid
    )

    matched = False
    output = []

    try:
        # 逐行读取输出
        for line in iter(proc.stdout.readline, ''):
            line_stripped = line.strip()
            output.append(line_stripped)
            if match_str in line:
                matched = True
                # 终止整个进程组
                os.killpg(os.getpgid(proc.pid), signal.SIGTERM)
                break
        proc.wait()
    except Exception as e:
        module.fail_json(msg=f"执行异常: {str(e)}", output='\n'.join(output))

    if matched:
        module.exit_json(
            changed=True,
            msg=f"匹配到目标字符串「{match_str}」，已终止命令",
            output='\n'.join(output),
            return_code=proc.returncode
        )
    else:
        module.exit_json(
            changed=False,
            msg="命令执行完毕，未匹配到目标字符串",
            output='\n'.join(output),
            return_code=proc.returncode
        )

if __name__ == '__main__':
    main()

使用自定义模块 #

将上述文件放到Ansible的模块目录（比如playbook同级的library文件夹），然后在Playbook中调用：

- name: 执行阻塞命令并等待匹配输出
  custom_wait_command:
    command: "your_blocking_command"
    match_string: "需要匹配的特定输出"

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