亚马逊DynamoDB
生活随笔
收集整理的這篇文章主要介紹了
亚马逊DynamoDB
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
介紹
- Amazon DynamoDB是一項完全托管的NoSQL數據庫服務，可提供無縫的可擴展性和快速可預測的性能。
- Amazon DynamoDB自動將表的數據和流量分布在足夠數量的服務器上，以處理客戶指定的請求容量和存儲的數據量，同時保持一致且快速的性能。
- 所有數據項都存儲在固態磁盤（SSD）上，并自動跨區域中的多個可用區復制，以提供內置的高可用性和數據持久性。
- 您可以通過AWS管理控制臺啟動新的Amazon DynamoDB數據庫表，在不停機或性能下降的情況下擴展或縮減對該表的請求容量，并獲得對資源利用率和性能指標的可見性。
- 借助Amazon DynamoDB，您可以將操作和擴展分布式數據庫的管理負擔轉移到AWS，因此您不必擔心硬件設置，設置和配置，復制，軟件修補或集群擴展。
- SDK： http ： //aws.amazon.com/sdkforjava/
Amazon DynamoDB注釋
- @DynamoDBTable
標識Amazon DynamoDB中的目標表。 例如，以下Java代碼段定義了一個類Developer，并將其映射到Amazon DynamoDB中的People表。
@DynamoDBTable(tableName="People") public class Developer { ...}- @DynamoDBIgnore
向DynamoDBMapper實例指示應該忽略關聯的屬性。 將數據保存到表時，DynamoDBMapper不會將此屬性保存到表中。
- @DynamoDBAttribute
將屬性映射到表屬性。 默認情況下，每個類屬性都映射到具有相同名稱的item屬性。 但是，如果名稱不同，則可以使用此標記將屬性映射到屬性。 在以下Java代碼段中，DynamoDBAttribute將BookAuthors屬性映射到表中的Authors屬性名稱。
@DynamoDBAttribute(attributeName = "Authors") public List<String> getBookAuthors() { return BookAuthors; } public void setBookAuthors(List<String> BookAuthors) { this.BookAuthors = BookAuthors; }將對象保存到表時，DynamoDBMapper使用作者作為屬性名稱。
- @DynamoDBHashKey
將類屬性映射到表的hash屬性。 該屬性必須是受支持的String或Numeric類型之一，并且不能是集合類型。
假設您有一個表ProductCatalog，該表具有ID作為主鍵。 以下Java代碼段定義了CatalogItem類，并使用@DynamoDBHashKey標記將其id屬性映射到ProductCatalog表的主鍵。
@DynamoDBTable(tableName="ProductCatalog") public class CatalogItem {private String Id; @DynamoDBHashKey(attributeName="Id")public String getId() {return Id;}public void setId(String Id) {this.Id = Id;}// Additional properties go here. }- @DynamoDBRangeKey
將類屬性映射到表的范圍鍵屬性。 如果主鍵是由哈希鍵和范圍鍵屬性組成的，則可以使用此標記將您的類字段映射到范圍屬性。 例如，假定您有一個“回復”表，其中存儲有論壇主題的回復。 每個線程可以有很多回復。 因此，該表的主鍵是ThreadId和ReplyDateTime。 ThreadId是哈希屬性，ReplyDateTime是范圍屬性。 以下Java代碼段定義了Reply類，并將其映射到Reply表。 它同時使用@DynamoDBHashKey和@DynamoDBRangeKeytags來標識映射到主鍵的類屬性。
@DynamoDBTable(tableName="Reply") public class Reply {private String id;private String replyDateTime;@DynamoDBHashKey(attributeName="Id")public String getId() { return id; }public void setId(String id) { this.id = id; }@DynamoDBRangeKey(attributeName="ReplyDateTime")public String getReplyDateTime() { return replyDateTime; }public void setReplyDateTime(String replyDateTime) { this.replyDateTime = replyDateTime; }// Additional properties go here. }- @DynamoDBAutoGeneratedKey
將哈希鍵或范圍鍵屬性標記為自動生成。 保存這些屬性時，對象持久性模型將生成一個隨機UUID。 只能將字符串屬性標記為自動生成的鍵。
以下代碼段演示了如何使用自動生成的密鑰。
@DynamoDBTable(tableName="AutoGeneratedKeysExample") public class AutoGeneratedKeys {private String id;private String payload;@DynamoDBHashKey(attributeName = "Id")@DynamoDBAutoGeneratedKeypublic String getId() { return id; }public void setId(String id) { this.id = id; }@DynamoDBAttribute(attributeName="payload")public String getPayload() { return this.payload };public String setPayload(String payload) { this.payload = payload }; public static void saveItem() {AutoGeneratedKeys obj = new AutoGeneratedKeys();obj.setPayload("abc123");// id field is null at this point DynamoDBMapper mapper = new DynamoDBMapper(dynamoDBClient);mapper.save(obj);System.out.println("Object was saved with id " + obj.getId());} }- @DynamoDBVersionAttribute
標識用于存儲樂觀鎖定版本號的類屬性。 DynamoDBMapper保存新項目時，會為此屬性分配一個版本號，并在每次更新該項目時將其遞增。 僅支持數字標量類型。
DynamoDBMapper類別
DynamoDBMapper類是Amazon DynamoDB的入口點。 它提供了與Amazon DynamoDB的連接，并使您能夠訪問各種表中的數據，對項目執行各種CRUD操作以及對表執行查詢和掃描。 此類提供以下關鍵操作，供您使用Amazon DynamoDB。
- 救
- 將指定的對象保存到表中。
- 加載
- 從表中檢索項目。
- 刪除
- 從表中刪除一個項目。
- 詢問
- 啟用表查詢。
該查詢返回Reply對象的集合。
- 掃描
- 掃描整個表。
- 掃描方法返回“延遲加載”集合。 它最初僅返回一頁結果，然后在需要時對下一頁進行服務調用。 要獲取所有匹配項，您僅需要遍歷unansweredThreads集合。
- batchDelete
- 使用對AmazonDynamoDB.batchWriteItem方法的一個或多個調用從一個或多個表中刪除對象。
- batchSave
- 使用對AmazonDynamoDB.batchWriteItem方法的一個或多個調用將對象保存到一個或多個表。
- batchWrite
- 使用對AmazonDynamoDB.batchWriteItem方法的一個或多個調用，將對象保存到一個或多個表并從一個或多個表中刪除對象。
- 計數
- 計算指定的掃描表達式并返回匹配項的計數。
- marshallIntoObject
- 一種將結果從低級API轉換為域對象的實用程序方法。
支持的數據類型
Amazon DynamoDB支持以下原始數據類型和原始包裝器類。
- 串
- 布爾，布爾
- 字節，字節
- 日期（作為ISO8601毫秒精度的字符串，轉換為UTC）
- 日歷（作為ISO8601毫秒精度的字符串，已轉換為UTC）
- 好久好久
- 整數，整數
- 雙倍
- 浮，浮
- 大十進制
- 大整數
Amazon DynamoDB支持Java Set集合類型。 如果映射的集合屬性不是Set，則將引發異常。
下表總結了前面的Java類型如何映射到Amazon DynamoDB類型。
| Java類型 | Amazon DynamoDB類型 |
| 所有數字類型 | N（數字類型） |
| 弦樂 | S（字符串類型） |
| 布爾值 | N（數字類型），0或1。 |
| 字節緩沖區 | B（二進制類型） |
| 日期 | S（字符串類型）。 日期值存儲為ISO-8601格式的字符串。 |
| 設置收集類型 | SS（字符串集）類型，NS（數字集）類型或BS（二進制集）類型。 |
Java示例：CRUD操作
CatalogItem.java
import java.util.Set; import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBAttribute; import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBHashKey; import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBTable; @DynamoDBTable(tableName="ProductCatalog") public class CatalogItem {private Integer id;private String title;private String ISBN;private Set bookAuthors;@DynamoDBHashKey(attributeName="Id")public Integer getId() { return id; }public void setId(Integer id) { this.id = id; }@DynamoDBAttribute(attributeName="Title")public String getTitle() { return title; } public void setTitle(String title) { this.title = title; }@DynamoDBAttribute(attributeName="ISBN")public String getISBN() { return ISBN; } public void setISBN(String ISBN) { this.ISBN = ISBN;}@DynamoDBAttribute(attributeName = "Authors")public Set getBookAuthors() { return bookAuthors; } public void setBookAuthors(Set bookAuthors) { this.bookAuthors = bookAuthors; }@Overridepublic String toString() {return "Book [ISBN=" + ISBN + ", bookAuthors=" + bookAuthors+ ", id=" + id + ", title=" + title + "]"; } }ObjectPersistenceCRUDExample.java
import java.io.IOException; import java.util.Arrays; import java.util.HashMap; import java.util.HashSet; import java.util.Map; import java.util.Random;import com.amazonaws.AmazonClientException; import com.amazonaws.AmazonServiceException; import com.amazonaws.auth.AWSCredentials; import com.amazonaws.auth.ClasspathPropertiesFileCredentialsProvider; import com.amazonaws.regions.Region; import com.amazonaws.regions.Regions; import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClient; import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper; import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig; import com.amazonaws.services.dynamodbv2.model.AttributeDefinition; import com.amazonaws.services.dynamodbv2.model.AttributeValue; import com.amazonaws.services.dynamodbv2.model.ComparisonOperator; import com.amazonaws.services.dynamodbv2.model.Condition; import com.amazonaws.services.dynamodbv2.model.CreateTableRequest; import com.amazonaws.services.dynamodbv2.model.DescribeTableRequest; import com.amazonaws.services.dynamodbv2.model.KeySchemaElement; import com.amazonaws.services.dynamodbv2.model.KeyType; import com.amazonaws.services.dynamodbv2.model.ProvisionedThroughput; import com.amazonaws.services.dynamodbv2.model.ScalarAttributeType; import com.amazonaws.services.dynamodbv2.model.ScanRequest; import com.amazonaws.services.dynamodbv2.model.ScanResult; import com.amazonaws.services.dynamodbv2.model.TableDescription; import com.amazonaws.services.dynamodbv2.model.TableStatus;public class ObjectPersistenceCRUDExample {static AmazonDynamoDBClient client;private DynamoDBMapper mapper;private static int PRODUCT_ID;public static void main(String[] args) throws IOException {ObjectPersistenceCRUDExample demo = new ObjectPersistenceCRUDExample();demo.init();demo.createTable("ProductCatalog");for (int i = 0; i < 100; i++) {System.out.println(i);PRODUCT_ID = PRODUCT_ID + i;demo.insert();}demo.getAllRows();CatalogItem itemRetrieved = demo.load(PRODUCT_ID);demo.update(itemRetrieved);CatalogItem updatedItem = demo.load(PRODUCT_ID);demo.delete(updatedItem);demo.load(updatedItem.getId());System.out.println("Example complete!");}private void init() {PRODUCT_ID = new Random().nextInt(1000);AWSCredentials credentials = new ClasspathPropertiesFileCredentialsProvider().getCredentials();client = new AmazonDynamoDBClient(credentials);Region usWest2 = Region.getRegion(Regions.US_WEST_2);client.setRegion(usWest2);mapper = new DynamoDBMapper(client);}private void createTable(String tableName) {try {CreateTableRequest createTableRequest = new CreateTableRequest().withTableName(tableName);createTableRequest.withKeySchema(new KeySchemaElement().withAttributeName("Id").withKeyType(KeyType.HASH));createTableRequest.withAttributeDefinitions(new AttributeDefinition().withAttributeName("Id").withAttributeType(ScalarAttributeType.N));createTableRequest.withProvisionedThroughput(new ProvisionedThroughput().withReadCapacityUnits(10L).withWriteCapacityUnits(10L));TableDescription createdTableDescription = client.createTable(createTableRequest).getTableDescription();System.out.println("Created Table: " + createdTableDescription);// Wait for it to become activewaitForTableToBecomeAvailable(tableName);} catch (AmazonServiceException e) {e.printStackTrace();} catch (AmazonClientException e) {e.printStackTrace();}}private void waitForTableToBecomeAvailable(String tableName) {System.out.println("Waiting for " + tableName + " to become ACTIVE...");long startTime = System.currentTimeMillis();long endTime = startTime + (10 * 60 * 1000);while (System.currentTimeMillis() < endTime) {try {Thread.sleep(1000 * 20);} catch (Exception e) {}try {DescribeTableRequest request = new DescribeTableRequest().withTableName(tableName);TableDescription tableDescription = client.describeTable(request).getTable();String tableStatus = tableDescription.getTableStatus();System.out.println(" - current state: " + tableStatus);if (tableStatus.equals(TableStatus.ACTIVE.toString()))return;} catch (AmazonServiceException ase) {if (ase.getErrorCode().equalsIgnoreCase("ResourceNotFoundException") == false)throw ase;}}throw new RuntimeException("Table " + tableName + " never went active");}private void insert() {CatalogItem item = new CatalogItem();item.setId(PRODUCT_ID);item.setTitle("Book PRODUCT_ID");item.setISBN("611-1111111111");item.setBookAuthors(new HashSet(Arrays.asList("Author1","Author2")));// Save the item (book).mapper.save(item);}private void update(CatalogItem itemRetrieved) {itemRetrieved.setISBN("622-2222222222");itemRetrieved.setBookAuthors(new HashSet(Arrays.asList("Author1", "Author3")));mapper.save(itemRetrieved);System.out.println("Item updated:");System.out.println(itemRetrieved);}private void delete(CatalogItem updatedItem) {// Delete the item.mapper.delete(updatedItem);}private CatalogItem load(int id) {// Retrieve the updated item.DynamoDBMapperConfig config = new DynamoDBMapperConfig(DynamoDBMapperConfig.ConsistentReads.CONSISTENT);CatalogItem updatedItem = mapper.load(CatalogItem.class, id, config);if (updatedItem == null) {System.out.println("Done - Sample item is deleted.");} else {System.out.println("Retrieved item:");System.out.println(updatedItem);}return updatedItem;}private void getAllRows() {ScanRequest scanRequest = new ScanRequest().withTableName("ProductCatalog");scanRequest.setLimit(10);HashMap scanFilter = new HashMap();Condition condition = new Condition().withComparisonOperator(ComparisonOperator.EQ.toString()).withAttributeValueList(new AttributeValue().withS("611-1111111111"));scanFilter.put("ISBN", condition);Condition condition2 = new Condition().withComparisonOperator(ComparisonOperator.LE.toString()).withAttributeValueList(new AttributeValue().withN("1000"));scanFilter.put("Id", condition2);scanRequest.withScanFilter(scanFilter);try {System.out.println("Scan Request: " + scanRequest);ScanResult scanResponse = client.scan(scanRequest);for (Map item : scanResponse.getItems()) {System.out.println(item.get("Id").getN() + " , " +item.get("ISBN").getS() + " , " +item.get("Authors").getSS() + " , " +item.get("Title").getS());}System.out.println("Scan Response: " + scanResponse);System.out.println("Count: " + scanResponse.getCount());System.out.println("Scanned Count: "+ scanResponse.getScannedCount());System.out.println("Items: " + scanResponse.getItems());} catch (AmazonServiceException e) {e.printStackTrace();} catch (AmazonClientException e) {e.printStackTrace();}} } 參考： Sunil Gulabani博客上的JCG合作伙伴 Sunil Gulabani的Amazon DynamoDB 。翻譯自: https://www.javacodegeeks.com/2013/08/amazon-dynamodb.html
總結
以上是生活随笔為你收集整理的亚马逊DynamoDB的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 线程跳动
- 下一篇： 使用JaCoCo Maven插件为单元和