Serverless 入门（六）- DynamoDB 数据库

0. DynamoDB 是什么

Amazon DynamoDB 是一种完全托管的 NoSQL 数据库服务，提供快速而可预测的性能，能够实现无缝扩展。我们可以使用 DynamoDB 创建一个数据库表来存储和检索任何大小的数据，并处理任何级别的请求流量。DynamoDB 可自动将表的数据和流量分布到足够多的服务器中，以处理客户指定的请求容量和数据存储量，同时保持一致的性能和高效的访问。

1. DynamoDB 核心组件

在 DynamoDB 中，tables、items 和 attributes 是您使用的核心组件。table 是 items 的集合，而每个item是 attributes 的集合。DynamoDB 使用主键来唯一标识表中的每个项目，并且使用二级索引来提供更大的查询灵活性。您可以使用 DynamoDB 流 捕获 DynamoDB 表中的数据修改事件

Table – 类似于其他数据库系统，DynamoDB 将数据存储在表中。Table是数据的集合。例如 People 表，该表可用于存储有关好友、家人或关注的任何其他人的个人联系信息。

Item – 类似于数据行，具有不同于所有其他项目的唯一标识。在 People 表中，每个Item表示一位人员。

Attribute – 每个Item包含一个或多个attributes。Attributes 是基础的数据元素，无需进一步分解。例如，People 表中的一个Item包含名为 PersonID、LastName、FirstName 等的属性。

2. 创建项目

sls create --template aws-nodejs-typescript --path helloDynamoDB，从这篇开始，我们使用 TypeScript 模板来学习 Serverless 技术。

3. 配置数据库环境

Amazon 还是一个良心公司，提供了本地测试数据库来模拟线上 DynamoDB，从而减少开发期间的账单费用，提升开发效率（操作本地数据库肯定要比线上快）。

• 下载DynamoDB Local， 亚洲有这么两个地址：
  新加坡：https://s3-ap-southeast-1.amazonaws.com/dynamodb-local-singapore/dynamodb_local_latest.zip
  东京：https://s3-ap-northeast-1.amazonaws.com/dynamodb-local-tokyo/dynamodb_local_latest.zip

注：如果想运行.jar 文件，电脑上必须安装了 Java 6 以上运行环境。在 Terminal 里执行 java -version 来检查自己的电脑环境

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 文件，然后进入该目录，如图：

  
  

• 启动本地 DynamoDB 数据库

在解压后的当前目录执行： java -Djava.library.path=./DynamoDBLocal_lib -jar DynamoDBLocal.jar -sharedDb --port 8000

默认占用电脑的8000端口，如图所示：

启动成功后，就不要关这个 Terminal，一关 Terminal 数据库服务也跟着关了。

• 连接数据库
  官方暂时（截止2019-3-15）没有提供 GUI 客户端，但 github 上已有好心人提供，地址：
  https://github.com/touchduck/dynamon

启动 DynamoDB 软件客户端后，建议如图填写：

注意：我们这次使用的是本地数据库，所以 AWS Access Key ID 和 AWS Secret Key 可以随意填写，只要别空着就行

AWS Region、 AWS Access Key ID 和 AWS Secret Key 是如何获得？ 见：Serverless 入门（一） - 创建 IAM

我们在软件客户端看不到任何数据，如图所示：

连接后默认是没有数据的，接下来我们用 Node.js 代码来做 CRUD 操作。

4.操作本地数据库

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

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

• 创建 model，新建名为 models/movie.ts 文件

export const modelsMovie = {
  AttributeDefinitions: [ // 主键数据类型
    { AttributeName: "year", AttributeType: "N" }, // N Number
    { AttributeName: "title", AttributeType: "S" },   // S String
  ],
  KeySchema: [       // 主键
    { AttributeName: "year", KeyType: "HASH" },  // Partition key 分区键
    { AttributeName: "title", KeyType: "RANGE" },  // Sort key 排序键
  ],
  ProvisionedThroughput: { // DynamoDB 吞吐量配置
    ReadCapacityUnits: 20,
    WriteCapacityUnits: 20,
  },
  TableName: "Movies", // 表名
};

• 创建 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;

• 创建建表代码，新建名为 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 # 用于离线调试

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. 创建数据表

• 如果 DynamoDBLocal 数据库服务器关了，进入 dynamodb_local_latest 目录下，再次启动 java -Djava.library.path=./dynamodb_local_latest/DynamoDBLocal_lib -jar DynamoDBLocal.jar -sharedDb --port 8000
• 在项目根目录下执行 sls offline --useSeparateProcesses 启动 serverless 服务
• 然后浏览器输入 http://localhost:3000/create

Movies 表创建成功

再次启动 DynamoDB GUI 客户端，就会看到 Movies 表已经创建好了。如图所示：

如果再次调用 create 接口，就会报如下错误：

下篇文章我们介绍如何对表进行增、删、改、查，尽请期待！

相关文章

• Serverless 入门（一） - 创建 IAM https://www.jianshu.com/p/9fb731a799e2
• Serverless 入门（二） - HelloWord https://www.jianshu.com/p/ddf2ffda5f63
• Serverless 入门（三）- 初始项目解读 https://www.jianshu.com/p/8baba2a8fe9f
• Serverless 入门（四）- 如何调试 https://www.jianshu.com/p/58d30915de8a
• Serverless 入门（五）- 常用命令 https://www.jianshu.com/p/28f001ea9d9d
• Serverless 入门（六）- DynamoDB 数据库 https://www.jianshu.com/p/c313b61d1cbf