Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- {
- "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"
- }
- ]
- }
- {
- "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"
- }
- }
- @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;
- }
- {
- _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"
- }
- },
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement