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

将 Aurora 无服务器与 AWS AppSync

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

创建集群

在向其中添加RDS数据源之前，必须先 AppSync 在 Aurora Serverless 集群API上启用数据，然后使用 AWS Secrets Manager配置密钥。您可以先通过以下方式创建 Aurora 无服务器集群： AWS 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为集群返回。

使用上一步中的USERNAME和 COMPLEX _，通过 AWS Secrets Manager 控制台或使用输入文件创建 Secret，如下PASSWORD所示：CLI


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

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


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

这将返回 a fo ARN r secret。

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

启用数据 API

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

创建数据库和表

启用数据后，API您可以确保其与中的aws rds-data execute-statement命令配合使用 AWS CLI。这将确保在将 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 架构

现在，您API的 Aurora Serverless 数据已通过表启动并运行，我们将创建一个 GraphQL 架构并附加用于执行变更和订阅的解析器。在 AWS 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 无服务器集群，第二个资源是你 AWS Secrets Manager ARN的。在单击 “创建” 之前，您需要BOTHARNs在 AppSync 数据源配置中提供。

配置解析器

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

通过变异创造一只宠物。 createPet字段
通过变异更新宠物。 updatePet字段
通过变异删除一只宠物。 deletePet字段
通过查询获取一只宠物。 getPet字段
通过查询列出所有宠物。 listPets字段
通过查询列出价格范围内的宠物。 listPetsByPriceRange字段

突变。 createPet

在 AWS AppSync 控制台的架构编辑器中，在右侧选择 Att ach Resolver fo createPet(input: CreatePetInput!): Pet r。选择您的 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 响应映射模板。