创建集群启用数据 API 创建数据库和表 GraphQl 架构配置解析程序运行更改运行查询输入净化

教程：Aurora Serverless

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

创建集群

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


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。

通过创建密钥Amazon Secrets Manager使用上一步中的 USERNAME 和 COPLEZ_PASSWORD，通过控制台或通过包含类似于以下内容的输入文件的 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 后，您可以确保它与aws rds-data execute-statement中的命令Amazon CLI. 这将确保在将 Aurora Serverless 集群添加到 AppSync API 之前已进行正确配置。首先创建一个名为TESTDB使用--sql像这样的参数：


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 架构并附加用于执行更改和订阅的解析程序。在中创建新 APIAmazon AppSync控制台并导航到架构页面，并输入以下内容：


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 ManagerARN。您需要提供都在单击之前，AppSync 数据源配置中的 ARNCreate.

配置解析程序

现在，我们有一个有效的 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', '$ctx.args.input.type', $ctx.args.input.price)",
        "select * from Pets WHERE id = '$id'"
    ]
}

SQL 语句将根据语句数组中的顺序依次执行。结果将以相同的顺序返回。由于这是一种突变，我们运行选择之后的声明插入以检索已提交的值以填充 GraphQL 响应映射模板。