Advertisement
Guest User

Untitled

a guest
Jan 24th, 2017
106
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 4.77 KB | None | 0 0
  1. {
  2. "Records": [
  3. {
  4. "eventID": "1",
  5. "eventVersion": "1.0",
  6. "dynamodb": {
  7. "Keys": {
  8. "Id": {
  9. "N": "101"
  10. }
  11. },
  12. "NewImage": {
  13. "Message": {
  14. "S": "New item!"
  15. },
  16. "Id": {
  17. "N": "101"
  18. }
  19. },
  20. "StreamViewType": "NEW_AND_OLD_IMAGES",
  21. "SequenceNumber": "111",
  22. "SizeBytes": 26
  23. },
  24. "awsRegion": "us-west-2",
  25. "eventName": "INSERT",
  26. "eventSourceARN": eventsourcearn,
  27. "eventSource": "aws:dynamodb"
  28. },
  29. {
  30. "eventID": "2",
  31. "eventVersion": "1.0",
  32. "dynamodb": {
  33. "OldImage": {
  34. "Message": {
  35. "S": "New item!"
  36. },
  37. "Id": {
  38. "N": "101"
  39. }
  40. },
  41. "SequenceNumber": "222",
  42. "Keys": {
  43. "Id": {
  44. "N": "101"
  45. }
  46. },
  47. "SizeBytes": 59,
  48. "NewImage": {
  49. "Message": {
  50. "S": "This item has changed"
  51. },
  52. "Id": {
  53. "N": "101"
  54. }
  55. },
  56. "StreamViewType": "NEW_AND_OLD_IMAGES"
  57. },
  58. "awsRegion": "us-west-2",
  59. "eventName": "MODIFY",
  60. "eventSourceARN": sourcearn,
  61. "eventSource": "aws:dynamodb"
  62. },
  63. {
  64. "eventID": "3",
  65. "eventVersion": "1.0",
  66. "dynamodb": {
  67. "Keys": {
  68. "Id": {
  69. "N": "101"
  70. }
  71. },
  72. "SizeBytes": 38,
  73. "SequenceNumber": "333",
  74. "OldImage": {
  75. "Message": {
  76. "S": "This item has changed"
  77. },
  78. "Id": {
  79. "N": "101"
  80. }
  81. },
  82. "StreamViewType": "NEW_AND_OLD_IMAGES"
  83. },
  84. "awsRegion": "us-west-2",
  85. "eventName": "REMOVE",
  86. "eventSourceARN": sourcearn,
  87. "eventSource": "aws:dynamodb"
  88. }
  89. ]
  90. }
  91.  
  92. {
  93. "id": {
  94. "S": "RIGHT-aa465568-f4c8-4822-9c38-7563ae0cd37b-1131286033464633.jpg"
  95. },
  96. "lines": {
  97. "L": [
  98. {
  99. "M": {
  100. "points": {
  101. "L": [
  102. {
  103. "L": [
  104. {
  105. "N": "0"
  106. },
  107. {
  108. "N": "874.5625"
  109. }
  110. ]
  111. },
  112. {
  113. "L": [
  114. {
  115. "N": "1765.320601851852"
  116. },
  117. {
  118. "N": "809.7800925925926"
  119. }
  120. ]
  121. },
  122. {
  123. "L": [
  124. {
  125. "N": "3264"
  126. },
  127. {
  128. "N": "740.3703703703704"
  129. }
  130. ]
  131. }
  132. ]
  133. },
  134. "type": {
  135. "S": "guard"
  136. }
  137. }
  138. }
  139. ]
  140. },
  141. "modified": {
  142. "N": "1483483932472"
  143. },
  144. "qastatus": {
  145. "S": "reviewed"
  146. }
  147. }
  148.  
  149. @Override
  150. public Object handleRequest(DynamodbEvent dynamodbEvent, Context context) {
  151.  
  152. List<DynamodbEvent.DynamodbStreamRecord> dynamodbStreamRecordlist = dynamodbEvent.getRecords();
  153.  
  154. DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient());
  155. log.info("Whole event - "+dynamodbEvent.toString());
  156.  
  157. dynamodbStreamRecordlist.stream().forEach(dynamodbStreamRecord -> {
  158. if(dynamodbStreamRecord.getEventSource().equalsIgnoreCase("aws:dynamodb")){
  159. log.info("one record - "+dynamodbStreamRecord.getDynamodb().toString());
  160. log.info(" getting N from new image "+dynamodbStreamRecord.getDynamodb().getNewImage().toString());
  161.  
  162. String tableName = getTableNameFromARN(dynamodbStreamRecord.getEventSourceARN());
  163. log.info("Table name :"+tableName);
  164.  
  165. Map<String, AttributeValue> keys = dynamodbStreamRecord.getDynamodb().getKeys();
  166. log.info(keys.toString());
  167.  
  168. AttributeValue attributeValue = keys.get("Id");
  169. log.info("Value of N: "+attributeValue.getN());
  170.  
  171. Table table = dynamoDB.getTable(tableName);
  172.  
  173.  
  174. }
  175. });
  176.  
  177. return dynamodbEvent;
  178. }
  179.  
  180. {
  181. _index: "bar-guard",
  182. _type: "bar-guard_type",
  183. _id: "LEFT-b1939610-442f-4d8d-9991-3ca54685b206-1147042497459511.jpg",
  184. _score: 1,
  185. _source: {
  186. @SequenceNumber: "4901800000000019495704485",
  187. @timestamp: "2017-01-04T02:24:20.560358",
  188. lines: [{
  189. points: [[0,
  190. 1222.7129629629628],
  191. [2242.8252314814818,
  192. 1254.702546296296],
  193. [4000.0000000000005,
  194. 1276.028935185185]],
  195. type: "barr"
  196. }],
  197. modified: 1483483934697,
  198. qastatus: "reviewed",
  199. id: "LEFT-b1939610-442f-4d8d-9991-3ca54685b206-1147042497459511.jpg"
  200. }
  201. },
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement