Serverless 入門(六)- DynamoDB 數(shù)據(jù)庫(上)

0. DynamoDB 是什么

Amazon DynamoDB 是一種完全托管的 NoSQL 數(shù)據(jù)庫服務(wù),提供快速而可預(yù)測的性能,能夠?qū)崿F(xiàn)無縫擴(kuò)展。我們可以使用 DynamoDB 創(chuàng)建一個數(shù)據(jù)庫表來存儲和檢索任何大小的數(shù)據(jù),并處理任何級別的請求流量。DynamoDB 可自動將表的數(shù)據(jù)和流量分布到足夠多的服務(wù)器中,以處理客戶指定的請求容量和數(shù)據(jù)存儲量,同時保持一致的性能和高效的訪問。

1. DynamoDB 核心組件

在 DynamoDB 中,tablesitemsattributes 是您使用的核心組件。table 是 items 的集合,而每個item是 attributes 的集合。DynamoDB 使用主鍵來唯一標(biāo)識表中的每個項目,并且使用二級索引來提供更大的查詢靈活性。您可以使用 DynamoDB 流 捕獲 DynamoDB 表中的數(shù)據(jù)修改事件

Table – 類似于其他數(shù)據(jù)庫系統(tǒng),DynamoDB 將數(shù)據(jù)存儲在表中。Table是數(shù)據(jù)的集合。例如 People 表,該表可用于存儲有關(guān)好友、家人或關(guān)注的任何其他人的個人聯(lián)系信息。

Item – 類似于數(shù)據(jù)行,具有不同于所有其他項目的唯一標(biāo)識。在 People 表中,每個Item表示一位人員。

Attribute – 每個Item包含一個或多個attributes。Attributes 是基礎(chǔ)的數(shù)據(jù)元素,無需進(jìn)一步分解。例如,People 表中的一個Item包含名為 PersonID、LastName、FirstName 等的屬性。

2. 創(chuàng)建項目

serverless create --template aws-nodejs-typescript --path helloDynamoDB,從這篇開始,我們使用 TypeScript 模板來學(xué)習(xí) Serverless 技術(shù)。

3. 配置數(shù)據(jù)庫環(huán)境

Amazon 還是一個良心公司,提供了本地測試數(shù)據(jù)庫來模擬線上 DynamoDB,從而減少開發(fā)期間的賬單費用,提升開發(fā)效率(操作本地數(shù)據(jù)庫肯定要比線上快)。

注:如果想運行.jar 文件,電腦上必須安裝了 Java 6 以上運行環(huán)境。在 Terminal 里執(zhí)行 java -version 來檢查自己的電腦環(huán)境

kenny@Kennys-MacBook-Pro ~/Downloads/dynamodb_local_latest $ java -version
java version "1.8.0_181"
Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)
  • 解壓 dynamodb_local_latest.zip 文件,然后進(jìn)入該目錄,如圖:


  • 啟動本地 DynamoDB 數(shù)據(jù)庫

在解壓后的當(dāng)前目錄執(zhí)行: java -Djava.library.path=./DynamoDBLocal_lib -jar DynamoDBLocal.jar -sharedDb --port 8000

默認(rèn)占用電腦的8000端口,如圖所示:

啟動成功后,就不要關(guān)這個 Terminal,一關(guān) Terminal 數(shù)據(jù)庫服務(wù)也跟著關(guān)了。

  • 連接數(shù)據(jù)庫
    官方暫時(截止2019-3-15)沒有提供 GUI 客戶端,但 github 上已有好心人提供,地址:
    https://github.com/touchduck/dynamon

啟動 DynamoDB 軟件客戶端后,建議如圖填寫:

注意:我們這次使用的是本地數(shù)據(jù)庫,所以 AWS Access Key ID 和 AWS Secret Key 可以隨意填寫,只要別空著就行

AWS Region、 AWS Access Key IDAWS Secret Key 是如何獲得? 見:Serverless 入門(一) - 創(chuàng)建 IAM

我們在軟件客戶端看不到任何數(shù)據(jù),如圖所示:


連接后默認(rèn)是沒有數(shù)據(jù)的,接下來我們用 Node.js 代碼來做 CRUD 操作。

4.操作本地數(shù)據(jù)庫

  • 添加 aws-sdk 包,yarn add aws-sdk

  • 添加 serverless-offline 包,yarn add serverless-offline -D

  • 創(chuàng)建 model,新建名為 models/movie.ts 文件

export const modelsMovie = {
  AttributeDefinitions: [ // 主鍵數(shù)據(jù)類型
    { AttributeName: "year", AttributeType: "N" }, // N Number
    { AttributeName: "title", AttributeType: "S" },   // S String
  ],
  KeySchema: [       // 主鍵
    { AttributeName: "year", KeyType: "HASH" },  // Partition key 分區(qū)鍵
    { AttributeName: "title", KeyType: "RANGE" },  // Sort key 排序鍵
  ],
  ProvisionedThroughput: { // DynamoDB 吞吐量配置
    ReadCapacityUnits: 20,
    WriteCapacityUnits: 20,
  },
  TableName: "Movies", // 表名
};
  • 創(chuàng)建 client,新建名為 dynamo-client.ts 文件
import { DynamoDB } from "aws-sdk";

const getDynamoClient = (event, port = 8000) => {
  if ("isOffline" in event && event.isOffline) {
    return new DynamoDB({ endpoint: `http://localhost:${port}` });
  }
  return new DynamoDB();
};

export default getDynamoClient;
  • 創(chuàng)建建表代碼,新建名為 table.ts 文件
import { APIGatewayProxyHandler } from 'aws-lambda';
import 'source-map-support/register';
import getDynamoClient from "./dynamo-client";
import { modelsMovie } from "./models/movie";

export const create: APIGatewayProxyHandler = async (event) => {
  const dynamodb = getDynamoClient(event);
  try {
    const { TableDescription = {} } = await dynamodb.createTable(modelsMovie).promise();
    return {
      body: JSON.stringify({
        creationDateTime: TableDescription.CreationDateTime,
        tableStatus: TableDescription.TableStatus,
        tableName: TableDescription.TableName,
        message: 'Table create successfully!',
      }),
      statusCode: 200,
    };
  } catch (e) {
    return {
      body: JSON.stringify(e),
      statusCode: 500,
    };
  }
};
  • 配置 serverless.yml,全部配置如下:
service:
  name: helloDynamoDB

plugins:
  - serverless-webpack
  - serverless-offline # 用于離線調(diào)試

provider:
  name: aws
  runtime: nodejs8.10
  stage: dev
  region: ap-northeast-2

functions:
  hello:
    handler: handler.hello
    events:
      - http:
          method: get
          path: hello
  createTable:
    # table.ts 文件放到 src 里了,所以要加 src
    handler: src/table.create
    events:
      - http:
          method: get
          path: create  # create 是路由名稱

代碼都寫完了,來驗證一下吧!

5. 創(chuàng)建數(shù)據(jù)表

  • 如果 DynamoDBLocal 數(shù)據(jù)庫服務(wù)器關(guān)了,進(jìn)入 dynamodb_local_latest 目錄下,再次啟動 java -Djava.library.path=./dynamodb_local_latest/DynamoDBLocal_lib -jar DynamoDBLocal.jar -sharedDb --port 8000
  • 在項目根目錄下執(zhí)行 serverless offline --useSeparateProcesses 啟動 serverless 服務(wù)
  • 然后瀏覽器輸入 http://localhost:3000/create
Movies 表創(chuàng)建成功

再次啟動 DynamoDB GUI 客戶端,就會看到 Movies 表已經(jīng)創(chuàng)建好了。如圖所示:

如果再次調(diào)用 create 接口,就會報如下錯誤:

下篇文章我們介紹如何對表進(jìn)行增、刪、改、查,盡請期待!

相關(guān)文章

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容