如何使用camel-ddb来保存json有效载荷

Question

我已经创建了dynamodb（EU-WEST-1）表并且创建了表，并且我创建了一个将json有效载荷放入表的camel路径。

我的路线是这样的：

String dynamoDbEndpoint = String.format("aws-ddb://tablename?accessKey=%s&secretKey=RAW(%s)&tableName=tablename&amazonDdbEndpoint=dynamodb.eu-west-1.amazonaws.com",awsAccessKey,awsSecretKey); 
from("direct:ipg-queue").to(dynamoDbEndpoint) 

我得到的错误信息：

com.amazonaws.AmazonServiceException：1验证错误检测：在 '项目' 值null不能满足约束：成员不能为null（服务：AmazonDynamoDB;状态代码：400;错误代码：ValidationException;请求ID：0AVSR54LRTOG3U0TTC5B1QO4KBVV4KQNSO5AEMVJF66Q9ASUAAJG）

示例有效负载为：

{"accountNumber":"123456789","customerName":"John Smith","id":"8422b9e0-739b-4d19-9291-037b68344068"} 

表示为字符串。

我在做一些愚蠢的事，但不能弄明白......

Answer 1

因此，原来我太傻了。你只需要在交换中设置CamelAwdDbItem头。我增加了后续的处理模块，以我的路线发电机分贝端点之前和离开我去......

.unmarshal() 
.json(JsonLibrary.Gson, Map.class) 
.process((Exchange exchange) -> { 
    Map body = (Map) exchange.getIn() 
          .getBody(); 

    Map<String, AttributeValue> newBody = new HashMap(); 

    for(Object key : body.keySet()) { 
     newBody.put(key.toString(), new AttributeValue(body.get(key).toString())); 
    } 

    exchange.getIn().setHeader("CamelAwsDdbItem", newBody); 
}) 

我也把&operation=PutItem到端点定义的结束。