2. CollectionEvent 定义：核心概念与生命周期

CollectionEvent 是事件驱动架构中数据采集的最小业务单元，它记录了一次“发生了什么”的完整事实。在报告订阅场景中，CollectionEvent 既是触发条件判定的输入源，也是订阅配置最终消费的数据载体。理解其定义、生命周期和元数据结构，是后续配置触发规则与订阅策略的基础。

2.1 什么是 CollectionEvent

CollectionEvent 是一个不可变的事实记录，表示在特定时间点、由特定实体发起的、具有明确业务含义的事件。它与传统日志或消息的区别在于：

• 业务语义明确：每个事件都携带预定义的业务类型（如 order.created、device.offline），而非原始文本。
• 结构化元数据：事件体遵循统一的数据模型，便于下游订阅者按字段过滤和聚合。
• 一次写入、多次消费：事件一旦生成即不可修改，可被多个订阅规则独立消费。

2.2 事件生命周期：四个阶段

一个 CollectionEvent 从产生到归档，经历四个明确的阶段。每个阶段对应不同的系统职责和订阅行为。

2.3 事件元数据结构设计

元数据是 CollectionEvent 的核心载荷，决定了订阅配置中“按什么条件触发”的能力边界。一个标准的事件元数据包含以下五个层级：

1. 事件头（Event Header）：全局唯一 ID、事件类型、版本号、创建时间戳。
2. 来源上下文（Source Context）：产生事件的系统、服务、租户、环境（prod/staging）。
3. 业务主体（Business Entity）：事件关联的业务对象 ID 和类型（如订单号、设备序列号）。
4. 事件载荷（Event Payload）：业务变更的具体字段，通常为 JSON 对象。
5. 扩展标签（Tags）：用于快速过滤的键值对集合，支持订阅规则中的标签匹配。

2.4 元数据字段规范表

2.5 事件元数据 JSON 示例

{
  "header": {
    "event_id": "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
    "event_type": "order.paid",
    "event_version": 2,
    "created_at": "2025-03-21T14:30:00.123Z"
  },
  "source": {
    "source_system": "order-service",
    "tenant_id": "tenant-001"
  },
  "entity": {
    "entity_id": "ORD-20250321-001",
    "entity_type": "order"
  },
  "payload": {
    "total_amount": 299.99,
    "currency": "CNY",
    "payment_method": "wechat_pay",
    "items": [
      {"sku": "BOOK-001", "quantity": 2, "price": 99.99}
    ]
  },
  "tags": {
    "region": "cn-east",
    "priority": "high",
    "channel": "mobile"
  }
}

2.6 生命周期与元数据的协同

元数据中的 event_type 和 created_at 直接决定了事件在生命周期中的流转路径：

• 创建阶段：系统根据 event_type 将事件路由到对应的订阅规则匹配器。
• 触发阶段：匹配器读取 tags 和 payload 中的字段，与订阅规则的条件表达式进行比对。
• 消费阶段：订阅者根据 entity_id 和 source_system 决定如何处理事件。
• 归档阶段：系统根据 created_at 计算保留时间，超过 TTL 后自动归档。