DynamoDB Stream 批处理中只有一项

问题描述

我正在通过 pulumi 创建一个表并像这样设置这些变量

streamEnabled: true
streamViewType: 'NEW_IMAGE',

然后我创建一个像下面这样的流作为触发器附加到表

new aws.dynamodb.TableEventSubscription(
  'the-stream-name','the-table-name',streamReceiverLambda,// The lambda to be passed the records
  {
    batchSize: 100,maximumBatchingWindowInSeconds: 60,startingPosition: 'LATEST',maximumRetryAttempts: 0,parallelizationFactor: 1,bisectBatchOnFunctionError: false,},)

这按预期工作并调用我的 lambda，但即使我一次插入多条记录，或在最小时间窗口内插入多条记录，我的流中也只有一项。我无法弄清楚我做错了什么。下面是我的 lambda 'streamReceiverLambda'。

export const handler: DynamoDBStreamHandler = async (
  event: DynamoDBStreamEvent,context: Context,callback: Callback<void>,): Promise<void> => {
  // This only ever has one item in it,im 100% sure 
  const data = event.Records as DynamoDBRecord[]
  // Do things eventually when stream working
  callback(null,undefined)
}

如果我在一次写入 dynamodb 时插入了 20 条记录，我希望流将它们全部放入一个流中，但相反，上面的 lambda 将被调用 20 次。我做错了什么？

提前致谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）