1.2. sink 的预期数据格式
此 Kamelet 需要 JSON 格式的正文,它必须包含定义 DynamoDB 项的主键值。JSON 字段和表属性值之间的映射是通过键完成的。例如,对于 '{"username":"oscerd", "city":"Rome"}' 输入, Kamelet 会插入或更新指定 AWS DynamoDB 表中的项目,并设置 'username' 和 'city' 属性的值。
对于 PutItem 操作,Json 正文定义所有项目属性。对于 DeleteItem 操作,Json 正文仅定义标识要删除的项目的主要键属性。对于 UpdateItem 操作,Json 正文定义了两个键属性,用于识别要更新的项目,以及项目上的所有项目属性更新。
给定的 JSON 正文可以使用 操作
、key
和 item
作为映射到对应属性值映射的顶级属性。
{ "operation": "PutItem" "key": {}, "item": {} }
{
"operation": "PutItem"
"key": {},
"item": {}
}