如何解决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 举报,一经查实,本站将立刻删除。