summaryrefslogtreecommitdiff
path: root/src/com/p4square/grow/backend/dynamo/DbTool.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/com/p4square/grow/backend/dynamo/DbTool.java')
-rw-r--r--src/com/p4square/grow/backend/dynamo/DbTool.java11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/com/p4square/grow/backend/dynamo/DbTool.java b/src/com/p4square/grow/backend/dynamo/DbTool.java
index 758dc0e..e030caf 100644
--- a/src/com/p4square/grow/backend/dynamo/DbTool.java
+++ b/src/com/p4square/grow/backend/dynamo/DbTool.java
@@ -368,6 +368,7 @@ public class DbTool {
String topicName = topic.getName();
+ Map<String, String> attributes = new HashMap<>();
File[] files = topic.listFiles(JSON_FILTER);
for (File file : files) {
String filename = file.getName();
@@ -375,10 +376,14 @@ public class DbTool {
byte[] encoded = Files.readAllBytes(file.toPath());
String value = new String(encoded, StandardCharsets.UTF_8);
- db.putAttribute(DynamoKey.newAttributeKey("strings",
- "/training/" + topicName, videoId), value);
- System.out.println("Inserted /training/" + topicName + ":" + videoId);
+
+ attributes.put(videoId, value);
+ System.out.println("Found /training/" + topicName + ":" + videoId);
}
+
+ db.putKey(DynamoKey.newKey("strings",
+ "/training/" + topicName), attributes);
+ System.out.println("Inserted /training/" + topicName);
}
}