非常基本的问题。我有两张DynamoDB桌子。表1包含一系列值,表2将包含一系列值(平均值等)。
我使用DynamoDB流触发lambda函数,从表1中的数据计算聚合值,然后用这些值更新表2。我的问题是,DynamoDB流是包含整个table1还是只包含新记录?
我只是调整lambda函数来计算平均值,并将其存储到表2中,我只是试图规划实现这一点的最佳方法。一切似乎都在运转。只是在从表1中获取数据时遇到了障碍。对于有关forEach记录的任何其他提示,我们也将不胜感激。非常感谢。
只有修改过的字段,否则每次流式传输整个数据库没有多大意义,对吗?. from the docs:https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.Tutorial.html
您将收到如下消息:
{
"Records": [
{
"eventID": "7de3041dd709b024af6f29e4fa13d34c",
"eventName": "INSERT",
"eventVersion": "1.1",
"eventSource": "aws:dynamodb",
"awsRegion": "us-west-2",
"dynamodb": {
"ApproximateCreationDateTime": 1479499740,
"Keys": {
"Timestamp": {
"S": "2016-11-18:12:09:36"
},
"Username": {
"S": "John Doe"
}
},
"NewImage": {
"Timestamp": {
"S": "2016-11-18:12:09:36"
},
"Message": {
"S": "This is a bark from the Woofer social network"
},
"Username": {
"S": "John Doe"
}
},
"SequenceNumber": "13021600000000001596893679",
"SizeBytes": 112,
"StreamViewType": "NEW_IMAGE"
},
"eventSourceARN": "arn:aws:dynamodb:us-east-1:123456789012:table/BarkTable/stream/2016-11-16T20:42:48.104"
}
]
}
不知道你需要什么样的聚合,也不知道你的用例,所以我对此无能为力。