如何访问Dynamodb的原始JSON元素？

Question

我正在尝试使用以下在测试中配置的dynamodb事件输入来手动测试我的lambda -

让我们将其命名为Json-1

 {
  "Records": [
    {
      "eventID": "1",
      "eventVersion": "1.0",
      "dynamodb": {
        "Keys": {
          "Id": {
            "N": "101"
          }
        },
        "NewImage": {
          "Message": {
            "S": "New item!"
          },
          "Id": {
            "N": "101"
          }
        },
        "StreamViewType": "NEW_AND_OLD_IMAGES",
        "SequenceNumber": "111",
        "SizeBytes": 26
      },
      "awsRegion": "us-west-2",
      "eventName": "INSERT",
      "eventSourceARN": eventsourcearn,
      "eventSource": "aws:dynamodb"
    },
    {
      "eventID": "2",
      "eventVersion": "1.0",
      "dynamodb": {
        "OldImage": {
          "Message": {
            "S": "New item!"
          },
          "Id": {
            "N": "101"
          }
        },
        "SequenceNumber": "222",
        "Keys": {
          "Id": {
            "N": "101"
          }
        },
        "SizeBytes": 59,
        "NewImage": {
          "Message": {
            "S": "This item has changed"
          },
          "Id": {
            "N": "101"
          }
        },
        "StreamViewType": "NEW_AND_OLD_IMAGES"
      },
      "awsRegion": "us-west-2",
      "eventName": "MODIFY",
      "eventSourceARN": sourcearn,
      "eventSource": "aws:dynamodb"
    },
    {
      "eventID": "3",
      "eventVersion": "1.0",
      "dynamodb": {
        "Keys": {
          "Id": {
            "N": "101"
          }
        },
        "SizeBytes": 38,
        "SequenceNumber": "333",
        "OldImage": {
          "Message": {
            "S": "This item has changed"
          },
          "Id": {
            "N": "101"
          }
        },
        "StreamViewType": "NEW_AND_OLD_IMAGES"
      },
      "awsRegion": "us-west-2",
      "eventName": "REMOVE",
      "eventSourceARN": sourcearn,
      "eventSource": "aws:dynamodb"
    }
  ]
}

然而，dynamodb项的json看起来像这样-

让我们称它为Json-2

{
  "id": {
    "S": "RIGHT-aa465568-f4c8-4822-9c38-7563ae0cd37b-1131286033464633.jpg"
  },
  "lines": {
    "L": [
      {
        "M": {
          "points": {
            "L": [
              {
                "L": [
                  {
                    "N": "0"
                  },
                  {
                    "N": "874.5625"
                  }
                ]
              },
              {
                "L": [
                  {
                    "N": "1765.320601851852"
                  },
                  {
                    "N": "809.7800925925926"
                  }
                ]
              },
              {
                "L": [
                  {
                    "N": "3264"
                  },
                  {
                    "N": "740.3703703703704"
                  }
                ]
              }
            ]
          },
          "type": {
            "S": "guard"
          }
        }
      }
    ]
  },
  "modified": {
    "N": "1483483932472"
  },
  "qastatus": {
    "S": "reviewed"
  }
}

使用下面的lambda函数，我可以连接到我的表。我的目标是创建一个弹性搜索可以接受的json。

@Override
    public Object handleRequest(DynamodbEvent dynamodbEvent, Context context) {

        List<DynamodbEvent.DynamodbStreamRecord> dynamodbStreamRecordlist = dynamodbEvent.getRecords();

        DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient());
        log.info("Whole event - "+dynamodbEvent.toString());

        dynamodbStreamRecordlist.stream().forEach(dynamodbStreamRecord -> {
            if(dynamodbStreamRecord.getEventSource().equalsIgnoreCase("aws:dynamodb")){
                log.info("one record - "+dynamodbStreamRecord.getDynamodb().toString());
                log.info(" getting N from new image "+dynamodbStreamRecord.getDynamodb().getNewImage().toString());

                String tableName = getTableNameFromARN(dynamodbStreamRecord.getEventSourceARN());
                log.info("Table name :"+tableName);

                Map<String, AttributeValue> keys = dynamodbStreamRecord.getDynamodb().getKeys();
                log.info(keys.toString());

                AttributeValue attributeValue = keys.get("Id");
                log.info("Value of N: "+attributeValue.getN());

                Table table = dynamoDB.getTable(tableName);


            }
        });

        return dynamodbEvent;
    }

elastic search期望的JSON项的格式是这样的，这就是我想要将测试输入json映射到的内容-

我们将其命名为Json-3

{
    _index: "bar-guard",
    _type: "bar-guard_type",
    _id: "LEFT-b1939610-442f-4d8d-9991-3ca54685b206-1147042497459511.jpg",
    _score: 1,
    _source: {
        @SequenceNumber: "4901800000000019495704485",
        @timestamp: "2017-01-04T02:24:20.560358",
        lines: [{
            points: [[0,
            1222.7129629629628],
            [2242.8252314814818,
            1254.702546296296],
            [4000.0000000000005,
            1276.028935185185]],
            type: "barr"
        }],
        modified: 1483483934697,
        qastatus: "reviewed",
        id: "LEFT-b1939610-442f-4d8d-9991-3ca54685b206-1147042497459511.jpg"
    }
},

所以我需要的是读取Json-1并将其映射到Json-3。然而，Json-1似乎并不完整，即它没有dynamodb json所具有的信息-类似于Json-2中的点和线。

因此，我尝试连接到原始表，然后使用ID读取线和点的附加信息。

我不确定这是不是正确的方法。基本上，我想找出一种方法来获得dynamodb的实际JSON，而不是具有属性类型的json。如何使用java从json-2中获取线和点？我知道我们在javascript中有DocumentClient，但我正在寻找java中的东西。

另外，我在这里遇到了一个转换器，但对我没有帮助-- https://github.com/aws/aws-sdk-js/blob/master/lib/dynamodb/converter.js

这是我应该使用DynamoDBMapper还是ScanJavaDocumentAPI的东西？

http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/datamodeling/DynamoDBMapper.html#marshallIntoObjects-java.lang.Class-java.util.List-com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig-

如果是，我有点不知道如何在下面的代码中这样做-

ScanRequest scanRequest = new ScanRequest().withTableName(tableName);
                ScanResult result = dynamoDBClient.scan(scanRequest);
                for(Map<String, AttributeValue> item : result.getItems()){
                    AttributeValue value = item.get("lines");
                    if(value != null){
                        List<AttributeValue> values = value.getL();
                        for(AttributeValue value2 : values){
                            //what next?
                        }
                    }
                }

Answer 1

好的，这似乎对我很有效。

ScanRequest scanRequest = new ScanRequest().withTableName(tableName);
                ScanResult result = dynamoDBClient.scan(scanRequest);

                for(Map<String, AttributeValue> item : result.getItems()){
                    AttributeValue value = item.get("lines");
                    if(value != null){
                        List<AttributeValue> values = value.getL();

                        for(AttributeValue value2 : values){

                                if(value2.getM() != null)
                            {
                                Map<String, AttributeValue> map = value2.getM();
                                        AttributeValue points = map.get("points");
                                    List<AttributeValue> pointsvalues = points.getL();
                                    if(!pointsvalues.isEmpty()){
                                        for(AttributeValue valueOfPoint : pointsvalues){
                                            List<AttributeValue> pointList = valueOfPoint.getL();
                                            for(AttributeValue valueOfPoint2 : pointList){

                                            }
                                        }
                                    }
                            }
                        }
                    }
                }