使用CallbackBase()实现Ansible任务的日志记录与分析

在Ansible中，可以使用CallbackBase()类来实现任务的日志记录与分析。CallbackBase()是Ansible的回调插件基类，通过继承该类并实现特定方法，可以实现自定义的日志记录和分析功能。

使用CallbackBase()类可以实现以下功能：

1. 记录任务的开始与结束时间；

2. 记录每个主机执行任务的结果；

3. 分析任务执行的状态，如成功、失败、跳过等；

4. 统计任务执行的时长；

5. 输出执行任务过程中的详细日志。

以下是一个使用CallbackBase()实现日志记录与分析的例子：

from ansible.plugins.callback import CallbackBase
from ansible import constants as C
import datetime

# 继承CallbackBase类并实现相关方法
class MyCallback(CallbackBase):
    
    def __init__(self):
        super(MyCallback, self).__init__()
        self.task_results = {}
        self.task_start_time = {}
        self.task_end_time = {}

    def v2_playbook_on_start(self, playbook):
        print("Playbook {} starting...".format(playbook._file_name))
    
    def v2_playbook_on_play_start(self, play):
        print("Play {} starting...".format(play.name))
    
    def v2_playbook_on_task_start(self, task, is_conditional):
        self.task_start_time[task._uuid] = datetime.datetime.now()
        print("Task {} starting...".format(task.name))
    
    def v2_runner_on_ok(self, result, **kwargs):
        self.task_results[result._task._uuid] = 'ok'
        self.task_end_time[result._task._uuid] = datetime.datetime.now()
        print("Task {} finished successfully.".format(result.task_name))
    
    def v2_runner_on_failed(self, result, **kwargs):
        self.task_results[result._task._uuid] = 'failed'
        self.task_end_time[result._task._uuid] = datetime.datetime.now()
        print("Task {} failed.".format(result.task_name))
    
    def v2_runner_on_skipped(self, result, **kwargs):
        self.task_results[result._task._uuid] = 'skipped'
        self.task_end_time[result._task._uuid] = datetime.datetime.now()
        print("Task {} skipped.".format(result.task_name))
    
    def v2_playbook_on_stats(self, stats):
        print("Playbook finished.")
        for task_uuid, result in self.task_results.items():
            task_start = self.task_start_time[task_uuid]
            task_end = self.task_end_time[task_uuid]
            task_duration = task_end - task_start
            print("Task {} finished with result {} in {} seconds.".format(
                task_uuid, result, task_duration.total_seconds()))

# 设置Ansible全局回调插件
C.DEFAULT_CALLBACK_PLUGIN_PATH = 'path/to/my_callback_plugin.py'

# 使用CallbackBase回调插件执行Ansible任务
ansible-playbook my_playbook.yml

在这个例子中，自定义的回调插件类MyCallback继承自CallbackBase，并实现了一系列回调方法，如v2_playbook_on_start、v2_playbook_on_task_start等。这些方法在任务执行的不同阶段会被依次调用。

在playbook的执行过程中，每个任务开始时会调用v2_playbook_on_task_start()方法，记录任务的开始时间；任务结束时会调用v2_runner_on_ok()、v2_runner_on_failed()或v2_runner_on_skipped()方法，记录任务的结果和结束时间。

最后，调用v2_playbook_on_stats()方法，输出整个playbook的执行结果和每个任务的执行时长。

通过使用CallbackBase()类，可以实现自定义的日志记录和分析功能，方便对Ansible任务的执行过程进行监控和分析。