faucet/event-adapter-rabbitmq

RabbitMQ事件通知适配器

镜像概述

该Docker镜像为Faucet提供RabbitMQ事件适配器，能够接入Faucet推送事件的Unix socket，实现事件的接收与转发。主要用于与Poseidon系统配合，是Poseidon运行的必要组件，不支持仅日志解析模式。

核心功能与特性

• 事件接入：接入Faucet推送事件的Unix socket，实时接收事件数据
• RabbitMQ集成：将接收的事件转发至RabbitMQ服务器，支持自定义RabbitMQ连接参数
• Poseidon兼容：作为Poseidon系统的必要组件，与Poseidon的RabbitMQ服务器协同工作
• 灵活配置：通过环境变量配置事件 socket 开关、RabbitMQ连接信息等参数

使用场景

• 与Poseidon系统配合使用，实现Faucet事件的处理与分发
• 开发测试环境中，通过RabbitMQ接收Faucet事件进行调试分析
• 需要通过RabbitMQ实现Faucet事件通知的网络管理场景

使用方法与配置说明

环境变量配置

以下环境变量用于配置适配器行为：

Docker Compose部署

与Poseidon配合使用

从Faucet顶层目录，先导出必要的环境变量：

bash
export FAUCET_EVENT_SOCK=1
export FA_RABBIT_HOST=<Poseidon运行IP>
# 可选配置其他环境变量

然后使用以下命令启动：

bash
docker-compose -f docker-compose.yaml \
               -f adapters/vendors/rabbitmq/docker-compose.yaml \
               up

包含RabbitMQ服务器（便捷模式）

如需同时启动RabbitMQ服务器，可添加额外的docker-compose文件：

bash
docker-compose -f docker-compose.yaml \
               -f adapters/vendors/rabbitmq/docker-compose-rabbitmq.yaml \
               -f adapters/vendors/rabbitmq/docker-compose.yaml \
               up

测试与开发

提供示例RabbitMQ消费者用于测试，默认连接上述RabbitMQ服务器（需设置FA_RABBIT_HOST=rabbitmq）：

1. 安装依赖：

bash
pip3 install -r adapters/vendors/rabbitmq/requirements.txt

2. 启动消费者：

bash
python3 adapters/vendors/rabbitmq/example_consumer.py

注意事项

• Poseidon系统必须使用此适配器，不支持仅日志解析模式
• Poseidon自带RabbitMQ服务器，使用时无需单独启动RabbitMQ（除非使用便捷模式）
• FA_RABBIT_HOST必须设置为Poseidon运行的IP地址，确保适配器能连接到Poseidon的RabbitMQ服务器