创建集群启用数据 API 创建数据库和表 GraphQL 架构配置解析器运行变更运行查询输入净化

教程：Aurora Serverless

Amazon AppSync 提供了一个数据源，用于对已启用数据 API 的 Amazon Aurora Serverless 集群执行 SQL 命令。您可以使用 AppSync 解析器通过 GraphQL 查询、变更和订阅对数据 API 执行 SQL 语句。

创建集群

在将 RDS 数据源添加到 AppSync 之前，您必须先在 Aurora Serverless 集群上启用数据 API 并使用 Amazon Secrets Manager 配置密钥。您可以先使用 Amazon CLI 创建一个 Aurora Serverless 集群：


aws rds create-db-cluster --db-cluster-identifier http-endpoint-test  --master-username USERNAME \
--master-user-password COMPLEX_PASSWORD --engine aurora --engine-mode serverless \
--region us-east-1

这将为集群返回一个 ARN。

使用上一步中的 USERNAME 和 COMPLEX_PASSWORD 通过 Amazon Secrets Manager 控制台创建一个密钥，也可以通过 CLI 使用如下输入文件创建密钥：


{
    "username": "USERNAME",
    "password": "COMPLEX_PASSWORD"
}

将其作为参数传递给 Amazon CLI：


aws secretsmanager create-secret --name HttpRDSSecret --secret-string file://creds.json --region us-east-1

这将为密钥返回 ARN。

记下稍后在创建数据源时在 AppSync 控制台中使用的 Aurora Serverless 集群和密钥的 ARN。

启用数据 API

您可以通过按照 RDS 文档中的说明操作来在您的集群上启用数据 API。在将数据 API 作为 AppSync 数据源添加之前，必须先启用它。

创建数据库和表

在启用数据 API 后，您可以确保它在 Amazon CLI 中使用 aws rds-data execute-statement 命令。这将确保在将 Aurora Serverless 集群添加到 AppSync API 之前已进行正确配置。首先，使用 --sql 参数创建一个名为 TESTDB 的数据库，如下所示：


aws rds-data execute-statement --resource-arn "arn:aws:rds:us-east-1:123456789000:cluster:http-endpoint-test" \
--schema "mysql"  --secret-arn "arn:aws:secretsmanager:us-east-1:123456789000:secret:testHttp2-AmNvc1"  \
--region us-east-1 --sql "create DATABASE TESTDB"

如果运行无误，请使用创建表 命令添加一个表：


aws rds-data execute-statement --resource-arn "arn:aws:rds:us-east-1:123456789000:cluster:http-endpoint-test" \
 --schema "mysql"  --secret-arn "arn:aws:secretsmanager:us-east-1:123456789000:secret:testHttp2-AmNvc1" \
 --region us-east-1 \
 --sql "create table Pets(id varchar(200), type varchar(200), price float)" --database "TESTDB"

如果一切运行正常，您可以继续在 AppSync API 中将集群添加为数据源。

GraphQL 架构

现在，您的 Aurora Serverless 数据 API 已通过表启动并运行，我们将创建一个 GraphQL 架构并附加用于执行变更和订阅的解析器。在 Amazon AppSync 控制台中创建一个新的 API，并导航到架构页面，然后输入以下内容：


type Mutation {
    createPet(input: CreatePetInput!): Pet
    updatePet(input: UpdatePetInput!): Pet
    deletePet(input: DeletePetInput!): Pet
}

input CreatePetInput {
    type: PetType
    price: Float!
}

input UpdatePetInput {
id: ID!
    type: PetType
    price: Float!
}

input DeletePetInput {
    id: ID!
}

type Pet {
    id: ID!
    type: PetType
    price: Float
}

enum PetType {
    dog
    cat
    fish
    bird
    gecko
}

type Query {
    getPet(id: ID!): Pet
    listPets: [Pet]
    listPetsByPriceRange(min: Float, max: Float): [Pet]
}

schema {
    query: Query
    mutation: Mutation
}

保存您的架构并导航到数据源页面，然后创建新的数据源。为数据源类型选择关系数据库，并提供一个友好名称。使用您在上一步中创建的数据库名称以及用来创建它的集群 ARN。对于角色，您可以让 AppSync 创建新角色，也可以使用与以下内容类似的策略创建角色：


{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "rds-data:DeleteItems",
                "rds-data:ExecuteSql",
                "rds-data:ExecuteStatement",
                "rds-data:GetItems",
                "rds-data:InsertItems",
                "rds-data:UpdateItems"
            ],
            "Resource": [
                "arn:aws:rds:us-east-1:123456789012:cluster:mydbcluster",
                "arn:aws:rds:us-east-1:123456789012:cluster:mydbcluster:*"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "secretsmanager:GetSecretValue"
            ],
            "Resource": [
                "arn:aws:secretsmanager:us-east-1:123456789012:secret:mysecret",
                "arn:aws:secretsmanager:us-east-1:123456789012:secret:mysecret:*"
            ]
        }
    ]
}

请注意，此策略中有两个需要获得角色访问权的语句。第一个资源是您的 Aurora Serverless 集群，第二个资源是您的 Amazon Secrets Manager ARN。在单击创建之前，您需要在 AppSync 数据源配置中提供这两个 ARN。

配置解析器

现在，我们有一个有效的 GraphQL 架构和一个 RDS 数据源，我们可以将解析器附加到架构上的 GraphQL 字段。我们的 API 将提供以下功能：

通过 Mutation.createPet 字段创建宠物
通过 Mutation.updatePet 字段更新宠物
通过 Mutation.deletePet 字段删除宠物
通过 Query.getPet 字段获取单个宠物
通过 Query.listPets 字段列出所有宠物
通过 Query.listPetsByPriceRange 字段列出价格范围内的宠物

Mutation.createPet

从 Amazon AppSync 控制台的架构编辑器中，在右侧为 createPet(input: CreatePetInput!): Pet 选择附加解析器。选择您的 RDS 数据源。在 request mapping template (请求映射模板) 部分中，添加以下模板：


#set($id=$utils.autoId())
{
"version": "2018-05-29",
    "statements": [
        "insert into Pets VALUES (:ID, :TYPE, :PRICE)",
        "select * from Pets WHERE id = :ID"
    ],
    "variableMap": {
        ":ID": "$ctx.args.input.id",
        ":TYPE": $util.toJson($ctx.args.input.type),
        ":PRICE": $util.toJson($ctx.args.input.price)
    }
}

SQL 语句将根据语句数组中的顺序依次执行。结果将以相同的顺序返回。由于这是一个变更，我们在 insert 后面运行 select 语句以检索提交的值，以便填充 GraphQL 响应映射模板。