Wie bekomme ich die reine JSON-Zeichenfolge von DynamoDB stream neues Bild?

Question

Ich habe eine Dynamodb-Tabelle mit Streaming aktiviert. Außerdem habe ich einen Trigger für diese Tabelle erstellt, der eine AWS-Lambda-Funktion aufruft. Innerhalb dieser Lambda-Funktion versuche ich, das neue Bild (Dynamodb-Element nach der Änderung) aus dem Dynamodb-Stream zu lesen und zu versuchen, die reine JSON-Zeichenfolge daraus zu erhalten. Meine Frage ist, wie bekomme ich die reine JSON-Zeichenfolge des DynamoDB-Elements, das über den Stream gesendet wurde? Ich benutze das unten stehende Code-Snippet, um das neue Image zu erhalten, aber ich habe keine Ahnung, wie ich den JSON-String daraus bekommen kann. Schätze deine Hilfe.

public class LambdaFunctionHandler implements RequestHandler<DynamodbEvent, Object> { 

@Override 
public Object handleRequest(DynamodbEvent input, Context context) { 
    context.getLogger().log("Input: " + input); 

    for (DynamodbStreamRecord record : input.getRecords()){ 

     context.getLogger().log(record.getEventID()); 
     context.getLogger().log(record.getEventName()); 
     context.getLogger().log(record.getDynamodb().toString()); 
     Map<String,AttributeValue> currentRecord = record.getDynamodb().getNewImage(); 

     //how to get the pure json string of the new image 
     //.............................................. 
    } 
    return "Successfully processed " + input.getRecords().size() + " records."; 
} 

}

Answer 1

Hast du einen Weg, dies zu tun, herauszufinden. Ein grober Weg ist es, einen eigenen Parser zu erstellen, aber wir wollen auch nicht mit diesem Ansatz gehen

Answer 2

Einen Weg gefunden, es sauber zu machen. Mit InternalUtils von aws-java-sdk-DynamoDB-1.11.15.jar

com.amazonaws.services.dynamodbv2.model.Record streamRecord = ((RecordAdapter) record).getInternalObject(); 
      // get order ready // 
      OrderFinal order = Utils.mapO2Object(
        InternalUtils.toSimpleMapValue(streamRecord.getDynamodb().getNewImage().get("document").getM()), 
        OrderFinal.class); 

Answer 3

Diese Bibliothek die Arbeit machen: dynamoDb-marshaler

var unmarshalJson = require('dynamodb-marshaler').unmarshalJson; 

console.log('jsonItem Record: %j', unmarshalJson(record.dynamodb.NewImage)); 

Answer 4

Unten ist der vollständige Code für von Dynamo JSON auf Standard JSON Konvertierung :

import com.amazonaws.services.dynamodbv2.document.Item; 
import com.amazonaws.services.dynamodbv2.document.internal.InternalUtils; 
import com.amazonaws.services.dynamodbv2.model.AttributeValue; 
import com.amazonaws.services.lambda.runtime.Context; 
import com.amazonaws.services.lambda.runtime.RequestHandler; 
import com.amazonaws.services.lambda.runtime.events.DynamodbEvent; 
import com.amazonaws.services.lambda.runtime.events.DynamodbEvent.DynamodbStreamRecord; 
import com.google.gson.Gson; 

import java.util.ArrayList; 
import java.util.List; 
import java.util.Map; 

/** 
* Main Lambda class to receive event stream, parse it to Survey 
* and process them. 
*/ 
public class SurveyEventProcessor implements 
     RequestHandler<DynamodbEvent, String> { 

    private static final String INSERT = "INSERT"; 

    private static final String MODIFY = "MODIFY"; 

    public String handleRequest(DynamodbEvent ddbEvent, Context context) { 

     List<Item> listOfItem = new ArrayList<>(); 
     List<Map<String, AttributeValue>> listOfMaps = null; 
     for (DynamodbStreamRecord record : ddbEvent.getRecords()) { 

      if (INSERT.equals(record.getEventName()) || MODIFY.equals(record.getEventName())) { 
       listOfMaps = new ArrayList<Map<String, AttributeValue>>(); 
       listOfMaps.add(record.getDynamodb().getNewImage()); 
       listOfItem = InternalUtils.toItemList(listOfMaps); 
      } 

      System.out.println(listOfItem); 
      try { 
       // String json = new ObjectMapper().writeValueAsString(listOfItem.get(0)); 
       Gson gson = new Gson(); 
       Item item = listOfItem.get(0); 

       String json = gson.toJson(item.asMap()); 
       System.out.println("JSON is "); 
       System.out.println(json); 
      }catch (Exception e){ 
       e.printStackTrace(); 
      } 
     } 


     return "Successfully processed " + ddbEvent.getRecords().size() + " records."; 
    } 
} 

Answer 5

zusammenfassend nur die Antwort von Himanshu Parmar:

Map<String, AttributeValue> newImage = record.getDynamodb().getNewImage(); 
List<Map<String, AttributeValue>> listOfMaps = new ArrayList<Map<String, AttributeValue>>(); 
listOfMaps.add(newImage); 
List<Item> itemList = InternalUtils.toItemList(listOfMaps); 
for (Item item : itemList) { 
    String json = item.toJSON(); 
}