如何在AWS中订阅系统全部事件并实现新事件自动订阅？

完全可行，无需第三方工具，用AWS原生服务就能实现。针对你的需求，提供两种落地方案：

方案1：EventBridge规则 + Lambda 动态管理订阅 #

• 核心逻辑：通过EventBridge捕获核心系统发布的所有事件，用Lambda判断是否已有对应SNS/SQS订阅，无则自动创建。
• 操作步骤：
  1. 创建EventBridge规则，事件模式匹配核心系统的所有事件（示例模式）：

     {
       "source": ["your-core-system-identifier"],
       "detail-type": ["*"]
     }
     

  2. 将规则目标配置为Lambda函数。
  3. Lambda内编写逻辑（以Python boto3为例）：
     • 解析事件的detail-type或自定义事件类型标识。
     • 调用list_subscriptions_by_topic（SNS）或检查EventBridge Pipes关联（SQS），判断该事件类型是否已订阅。
     • 未订阅则调用subscribe（SNS）创建订阅，或创建EventBridge Pipe将事件定向到SQS。
     • 用DynamoDB存储已订阅事件类型列表，避免重复操作。

方案2：EventBridge Schema Registry 触发自动订阅 #

• 核心逻辑：若核心系统会将事件Schema注册到EventBridge Schema Registry，监听Schema创建事件来自动生成转发规则。
• 操作步骤：
  1. 开启Schema Registry的事件通知，新Schema创建时会向EventBridge默认总线发送AWS::Schemas::Schema类型的SchemaCreated事件。
  2. 创建EventBridge规则匹配上述事件。
  3. Lambda接收到事件后，提取Schema关联的事件类型，自动创建新的EventBridge规则，将该类型事件转发到目标SNS/SQS。

关键注意事项 #

• 权限配置：Lambda需拥有创建EventBridge规则、SNS订阅、SQS队列访问（或Pipe创建）的权限，以及DynamoDB读写权限（若用做去重）。
• 避免循环：在EventBridge规则中排除Lambda自身产生的事件，防止触发无限循环。
• 去重机制：必须用DynamoDB或其他存储记录已处理的事件类型，避免重复创建订阅/规则。

内容的提问来源于stack exchange，提问作者Moshe Israel