如何让Datadog接收Salesforce自定义平台事件？

云上老周

2026-7-26

可行方案推荐

方案1：Salesforce Streaming API + 轻量中间服务转发

通过中间服务主动订阅Salesforce平台事件后转发到Datadog，完全避免Salesforce直接发起API请求。

步骤说明：
1. 确认Salesforce侧自定义平台事件已创建，给中间服务使用的Salesforce账号分配API Enabled权限和对应平台事件的订阅权限。
2. 搭建轻量服务（如Node.js/Python），用Salesforce Streaming API客户端库（Python用salesforce-streaming，Node.js用cometd）连接Salesforce，订阅目标平台事件的推送通道（格式为/event/Your_Custom_Event__e）。
3. 服务收到平台事件后，将数据格式化为Datadog事件要求的结构（含标题、内容、标签等），调用Datadog Events API发送事件。
4. 部署中间服务（如Heroku免费层、Docker容器或自有服务器），确保服务持续运行并处理重连逻辑。
优缺点：
- 优点：架构简单、成本低，对现有Salesforce配置改动小。
- 缺点：需维护中间服务稳定性，处理网络波动或Salesforce会话过期问题。

利用Salesforce与AWS EventBridge的原生集成，将平台事件推送到AWS后通过Lambda转发到Datadog，Salesforce无需编写API请求代码。

步骤说明：
1. 在Salesforce中配置EventBridge集成：进入Setup -> EventBridge，创建新集成，选择要推送的自定义平台事件，关联到AWS账户的EventBridge事件总线。
2. 在AWS控制台创建Lambda函数，设置触发源为EventBridge，指定对应事件总线和匹配Salesforce平台事件的规则。
3. 在Lambda函数中编写逻辑：解析EventBridge传入的Salesforce事件数据，转换为Datadog事件格式，调用Datadog API（可使用Datadog提供的AWS Lambda层简化依赖管理）。
4. 配置Lambda的IAM权限，允许其读取EventBridge事件和调用Datadog API。
优缺点：
- 优点：依赖云服务商原生服务，无需自行维护中间服务的高可用。
- 缺点：需要AWS账户，涉及跨云配置，有一定学习成本。

若已有Kafka集群，可通过Kafka作为中转层，让Datadog直接消费Salesforce事件。

步骤说明：
1. 配置Salesforce到Kafka的推送：使用MuleSoft Anypoint Platform或自定义连接器，将自定义平台事件发布到指定Kafka主题。
2. 在Datadog中启用Kafka集成，配置目标Kafka集群和主题，设置消息解析规则，将Salesforce平台事件字段映射为Datadog事件属性。
优缺点：
- 优点：适合已有Kafka生态的场景，可复用现有消息队列的监控和运维能力。
- 缺点：需要Kafka集群资源，配置复杂度较高。

内容的提问来源于stack exchange，提问作者Iago Richard