扩展Ansible任务执行过程中的CallbackBase()插件

Ansible 是一个自动化IT工具，它使用SSH进行通信，并使用Ansible模块来管理和配置远程主机。在Ansible任务执行过程中，可以通过CallbackBase()插件来自定义和扩展Ansible的回调机制。

CallbackBase()是Ansible回调插件的基类，它提供了一系列的回调方法，可以在不同的阶段插入自定义的逻辑代码。下面是一些常用的回调方法：

- v2_runner_on_start(self, host, task)：任务开始执行时调用的方法，可以获取到主机和任务对象。

- v2_runner_on_ok(self, result)：任务执行成功时调用的方法，可以获取到任务结果对象。

- v2_runner_on_failed(self, result, ignore_errors=False)：任务执行失败时调用的方法，可以获取到任务结果对象。

- v2_runner_on_unreachable(self, result)：任务无法连接到远程主机时调用的方法，可以获取到任务结果对象。

- v2_runner_on_skipped(self, result)：任务被跳过时调用的方法，可以获取到任务结果对象。

- v2_playbook_on_stats(self, stats)：playbook执行完毕后调用的方法，可以获取到playbook执行的统计信息。

下面是一个使用CallbackBase()插件的示例：

from ansible.plugins.callback import CallbackBase

class MyCallback(CallbackBase):
    def __init__(self):
        super(MyCallback, self).__init__()

    def v2_runner_on_ok(self, result, **kwargs):
        # 获取任务执行成功的主机名和标准输出
        host = result._host
        stdout = result._result.get('stdout')
        print(f"Task succeeded on {host}: {stdout}")

    def v2_runner_on_failed(self, result, **kwargs):
        # 获取任务执行失败的主机名和错误信息
        host = result._host
        stderr = result._result.get('stderr')
        print(f"Task failed on {host}: {stderr}")

    def v2_playbook_on_stats(self, stats, **kwargs):
        # 获取playbook执行的统计信息
        total_hosts = len(stats.processed.keys())
        unreachable_hosts = len(stats.failures.keys())
        print(f"Total hosts: {total_hosts}")
        print(f"Unreachable hosts: {unreachable_hosts}")

# 使用自定义的回调插件
from ansible import context
from ansible.executor.task_executor import TaskExecutor

# 显式指定回调插件
context.CLIARGS['stdout_callback'] = 'my_callback_plugin'

# 创建任务执行器
executor = TaskExecutor()

# 执行任务
executor.run()

在上面的示例中，我们创建了一个自定义的回调插件MyCallback，重写了v2_runner_on_ok()、v2_runner_on_failed()和v2_playbook_on_stats()等方法来自定义回调逻辑。然后，我们在执行任务之前显式指定回调插件为my_callback_plugin，创建任务执行器，并调用run()方法来执行任务。

通过自定义回调插件，我们可以根据实际需求来扩展和定制Ansible的回调机制。无论是在任务执行过程中获取任务结果，还是在playbook执行完毕后输出统计信息，自定义回调插件提供了灵活的扩展性，使得我们可以更好地进行任务监控和报告。