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 Antwort
0

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

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

profile picture
EXPERTE
beantwortet vor 3 Jahren

Du bist nicht angemeldet. Anmelden um eine Antwort zu veröffentlichen.

Eine gute Antwort beantwortet die Frage klar, gibt konstruktives Feedback und fördert die berufliche Weiterentwicklung des Fragenstellers.

Richtlinien für die Beantwortung von Fragen