有什么方法可以获取Java中dynamodb表的HashKey的属性名称吗?
e.g., if the dyanmodb table schema is
(
"HashKey, String", SSNId
"SortKey, Long", Pincode
"String", Name
)
So I should be able to get the output like this:-
getHashKeyAttributeName(String tableName) --> SSNId
getSortkeyAttributeName(String tableName) --> Pincode
getOtherAttributeList(String tableName) --> Name
最佳答案
您在描述表时只需要在keySchemas
和attributeDefinitions
上进行迭代。DynamodbTable
描述具有以下结构,(我正在使用clojure-aws,您可以使用aws cli查看表结构)
user=> (db/describe-table {:profile "aws-profile" :endpoint "us-west-2"} "KeyValueLookupTable1")
{:table {:key-schema [{:key-type "HASH", :attribute-name "leaseKey"}], :table-size-bytes 201, :attribute-definitions [{:attribute-name "leaseKey", :attribute-type "S"}], :creation-date-time #object[org.joda.time.DateTime 0x4c6ece3 "2017-06-07T15:50:35.057-07:00"], :item-count 1, :table-status "ACTIVE", :table-name "KeyValueLookupTable1", :provisioned-throughput {:read-capacity-units 10, :write-capacity-units 10, :number-of-decreases-today 0}, :table-arn "arn:aws:dynamodb:us-west-2:033814027302:table/KeyValueLookupTable1"}}
您可以在其中看到需要迭代的
key-schema
和attribute-definitions
键。1)请参阅
TableDescription#getKeySchema
的文档以获取HASH
和RANGE
键。java8的示例
DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient())
String getHashKeyAttributeName(String tableName) {
TableDescription tableSchema = dynamoDB.getTable(tableName).describe();
return tableSchema.getKeySchema().stream()
.filter(x -> x.getKeyType().equals(KeyType.HASH.toString()))
.findFirst().get().getAttributeName();
}
String getSortkeyAttributeName(String tableName) {
TableDescription tableSchema = dynamoDB.getTable(tableName).describe();
return tableSchema.getKeySchema().stream()
.filter(x -> x.getKeyType().equals(KeyType.RANGE.toString()))
.findFirst().get().getAttributeName();
}
2)对于其他字段,您需要迭代在
List<AttributeDefinitions>
上获得的tableDescription.getAttributeDefinitions
List<String> getOtherAttributeList(String tableName) {
DynamoDB dynamoDB = new DynamoDB(new AmazonDynamoDBClient());
TableDescription tableSchema = dynamoDB.getTable(tableName).describe();
return tableSchema.getAttributeDefinitions().stream()
.map(AttributeDefinition::getAttributeName)
.collect(Collectors.toList());
}