Kinesis 发送事件到 EventBridge

0

【以下的问题经过翻译处理】 我们试图在生产者将数据发布到Kinesis数据流后,向EventBridge发送一个事件。然后,我们希望配置EventBridge API目标将事件发送到Salesforce并创建平台事件。

Kinesis -> EventBridge -> Rule + Bus + API目的地 -> Salesforce

  1. 我们最初以为可以在EventBridge上设置规则,以便根据筛选条件将某些Kinesis事件路由到事件总线。但我们无法找到任何路由到EventBridge的Kinesis事件。我们是否需要在Kinesis和EventBridge之间添加额外一层?

  2. 然后我们尝试使用基于Lambda的方法。编写了一个带有Kinesis触发器和EventBridge目标的Lambda函数。虽然我们看到Lambda函数被执行,但目标从未被调用。进一步的研究表明,在Kinesis配置为触发器的Lambda中,成功时不支持目标。有人可以确认这一点吗?

寻找关于模式1和模式2是否可行以及可行的任何指导。

1개 답변
0

【以下的回答经过翻译处理】 1. 是的,您将需要一些计算资源,例如 Lambda 函数。该函数将从 Kinesis 中获取记录并将其写入 EventBridge。 2. 您是正确的,Lambda 目标仅适用于异步调用,而 Kinesis 不是异步的(它被称为事件源映射)。您应该在函数中编写代码,迭代payload中的记录并使用 EventBridge API 将它们发送到总线上。

您的架构应该如下:Kinesis-> Lambda-> EventBridge-> API 目的地-> Salesforce。

profile picture
전문가
답변함 3년 전

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인