让我们深入了解如何以通用方式聚合 webhook

核心方法是跟踪某个时间窗口内对某件商品的更新(可配置,我们以 5 分钟为起始时间)。这意味着 5 分钟内同一商店/帐户中同一商品的所有更新都将被视为“一次更改”。

我们使用 DynamoDB 表来跟踪更新 法国号码数据 以及代表“此” webhook 的相关 SQS 消息 ID。Lambda 函数写入 DynamoDB 表,下游工作程序从此表读取以查看是否需要处理当前消息。

 

提取 Lambda 函数

大部分工作都是在 ingest lambda 函数 在获得 JURI 的批准后 中进行的,用于聚合传入的 webhook。该过程使用 DynamoDB 表和 SQS,如下所示:

DynamoDB 中的每一行都有一个复合键,由以下内容组成

 

 

例如,对于Shopify 商店中的产品,它可能看起来像:

 

 

该窗口是以纪元时 WhatsApp 号码 间指定的窗口的结束时间。

DynamoDB 行中还有什么?还有 3 个其他属性:

返回頂端