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

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

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

profile picture
ESPERTO
con risposta 3 anni fa

Accesso non effettuato. Accedi per postare una risposta.

Una buona risposta soddisfa chiaramente la domanda, fornisce un feedback costruttivo e incoraggia la crescita professionale del richiedente.

Linee guida per rispondere alle domande