Ansible 支持多种类型的插件，这些插件可以帮助你扩展和定制 Ansible 的功能。每种插件类型都有其特定的用途和应用场景。今天我们一起学习动态库存插件和回调插件。

一、动态库存插件

Ansible 动态库存插件允许从各种外部数据源动态获取库存信息，包括主机、组别和变量。这些插件特别适用于云环境和大型基础设施，其中主机数量频繁变动或依赖特定服务（如 AWS、Azure、Google Cloud Platform）动态管理。

主要功能

1. 动态同步：自动同步外部数据源（如云服务提供商或自定义数据库）的主机状态和配置。
2. 减少维护：避免手动更新和维护库存文件，尤其是在主机经常变动的环境中。
3. 自动化扩展：根据外部服务的标签、属性等动态组织和分类主机。

示例：使用 AWS EC2 动态库存插件

假设你的基础设施部署在 AWS EC2，你可以使用 Ansible 的 AWS EC2 动态库存插件自动发现和使用这些实例。

1. 安装所需的 Ansible 集合

首先，确保安装了包含 EC2 动态库存插件的 Ansible 集合：

ansible-galaxy collection install amazon.aws

2. 配置 AWS 凭据

确保你的 AWS 访问凭据配置正确。通常，这可以通过设置环境变量或配置文件 ~/.aws/credentials 来完成：

[default]
aws_access_key_id = YOUR_ACCESS_KEY
aws_secret_access_key = YOUR_SECRET_KEY

3. 创建动态库存配置文件

创建一个名为 aws_ec2.yml 的文件，配置动态库存插件：

plugin: amazon.aws.ec2regions:- us-east-1  # 指定区域keyed_groups:- prefix: regionkey: placement.region- prefix: typekey: instance_type- key: tagsprefix: tag

这个配置文件定义了插件类型（amazon.aws.ec2），所要扫描的区域（例如 us-east-1），以及如何根据实例的区域、类型和标签创建分组。

4. 使用动态库存

现在，你可以在 Ansible playbook 中使用这个动态库存配置。创建一个简单的 playbook list-instances.yml：

- hosts: tag_Name_MyInstance  # 假设你的实例有一个标签 Name: MyInstancegather_facts: falsetasks:- name: Print instance informationdebug:msg: "Instance {{ inventory_hostname }} is in the group {{ group_names }}"

5. 执行 Playbook

使用以下命令执行 playbook，指定动态库存文件：

注意事项

• 动态库存插件通常需要特定的权限来访问外部数据源，确保你的安全策略允许这些操作。
• 在使用动态库存时，可能需要对应的 SDK 或 API 客户端库，确保这些库已正确安装。
• 动态库存配置可能根据你的具体需求而有所不同，如需要特定的过滤条件或组织方式。

动态库存插件是 Ansible 自动化的强大工具，特别是在云计算和大规模分布式环境中，它提供了一种高效的方式来管理和操作动态变化的主机资源。

二、回调插件（Callback Plugins）

Ansible 回调插件允许开发者在 Ansible 的执行过程中的特定点进行介入，执行自定义的动作。这些插件可以捕捉到任务的开始、结束、失败等事件，并对这些事件做出响应，如记录日志、发送通知、或统计信息等。

主要用途

1. 日志记录：自定义任务执行的日志记录方式和格式。
2. 通知发送：在任务执行结束或失败时发送通知到 Slack、邮件等。
3. 数据收集：收集执行数据用于性能监测或审计。
4. 界面更新：更新监控或仪表板界面。

示例：自定义日志记录回调插件

假设我们需要创建一个简单的回调插件，该插件在每个任务执行后记录信息到一个本地文件。

1. 创建回调插件文件

在 Ansible 配置目录或项目目录中创建一个名为 callback_plugins/ 的目录，然后在此目录下创建一个名为 my_logger.py 的文件：

from datetime import datetime
import os
from ansible.plugins.callback import CallbackBaseclass CallbackModule(CallbackBase):"""An example callback plugin that logs task results to a file."""CALLBACK_VERSION = 2.0CALLBACK_TYPE = 'notification'CALLBACK_NAME = 'my_logger'def __init__(self):super(CallbackModule, self).__init__()self.logfile = open('ansible_task_log.txt', 'a')def log(self, host, category, task, result):now = datetime.now().strftime('%Y-%m-%d %H:%M:%S')log_entry = f"{now} | {host} | {category} | {task} | {result}\n"self.logfile.write(log_entry)self.logfile.flush()def v2_runner_on_ok(self, result):task_name = result.task_namehost = result._host.get_name()self.log(host, 'OK', task_name, 'Success')def v2_runner_on_failed(self, result, ignore_errors=False):task_name = result.task_namehost = result._host.get_name()self.log(host, 'FAILED', task_name, 'Failed')def v2_playbook_on_stats(self, stats):self.logfile.close()

2. 配置 Ansible 使用自定义回调插件

在 ansible.cfg 文件中启用自定义回调插件：

[defaults]
stdout_callback = my_logger
callback_whitelist = my_logger

这里我们设置 stdout_callback 为我们的插件，这是因为通常只能有一个 stdout 类型的插件被激活。如果你只希望添加额外的功能并保持标准输出，可以不设置 stdout_callback，只需添加 callback_whitelist。

3. 执行 Playbook

执行任何 playbook 时，所有任务的执行结果都将被记录到 ansible_task_log.txt 文件中。

注意事项

• 确保文件路径、权限等设置正确，以便插件能够成功写入日志。
• 回调插件可以影响 Ansible 的性能，特别是在高频写入操作时，要注意性能调试和优化。
• 测试回调插件以确保它在各种情况下都能正常工作，特别是在错误处理和异常情况下。

通过使用回调插件，你可以非常灵活地扩展 Ansible 的功能，满足特定的日志记录、通知和数据收集需求，从而让自动化操作更加透明和易于管理。