in amazon-ecs-java-starter-kit-task/src/main/java/software/aws/ecs/java/starterkit/util/DDBUtil.java [34:57]
public boolean insertTaskStatus(DynamoDbClient ddbClient, String tableName, String hashKey, String rangeKey,
long workflowId, String ecsTaskId, String taskName, String status, String time) {
boolean itemInserted = false;
// Populate item
HashMap<String, AttributeValue> itemValues = new HashMap<String, AttributeValue>();
itemValues.put(hashKey, AttributeValue.builder().n(Long.toString(workflowId)).build());
itemValues.put(rangeKey, AttributeValue.builder().s(ecsTaskId).build());
itemValues.put("task_name", AttributeValue.builder().s(taskName).build());
itemValues.put("start_time", AttributeValue.builder().s(time).build());
itemValues.put("status", AttributeValue.builder().s(status).build());
// Create a PutItemRequest object
PutItemRequest request = PutItemRequest.builder().tableName(tableName).item(itemValues).build();
try {
ddbClient.putItem(request);
itemInserted = true;
System.out.printf("An item added to %s successfully. \n", tableName);
} catch (DynamoDbException e) {
System.err.println(e.getMessage());
System.exit(1);
}
return itemInserted;
}