type User {
username: String! ## Primary key
posts: [Post]
following: [Following]
}
type Following {
follower: String! ## Primary key
username: String! ## Sort key
posts: [Post]
}
type Post {
username: String! ## Primary key
postID: ID!
title: String
content: String
}
type Query {
getPostsByUsername(username: String!): User
}
schema {
query: Query
}
User.posts 解析器:
{
"version": "2017-02-28",
"operation": "Query",
"query": {
"expression": "username = :username",
"expressionValues": {
":username": $util.dynamodb.toDynamoDBJson($context.source.username)
}
}
}
$util.toJson($ctx.result.items)
User.following解析器
{
"version": "2017-02-28",
"operation": "Query",
"query": {
"expression": "follower = :follower",
"expressionValues": {
":follower": $util.dynamodb.toDynamoDBJson($context.source.username)
}
}
}
$util.toJson($ctx.result.items)
Following.posts解析器
{
"version": "2017-02-28",
"operation": "Query",
"query": {
"expression": "username = :username",
"expressionValues": {
":username": $util.dynamodb.toDynamoDBJson($context.source.username)
}
}
}
$util.toJson($ctx.result.items)
Query.getPostsByUsername解析器
{
"version": "2017-02-28",
"operation": "GetItem",
"key": {
"username": $util.dynamodb.toDynamoDBJson($ctx.args.username),
}
}
$util.toJson($ctx.result)
测试
用户表
PostTable
下表
现在我们可以通过用户名查询所有帖子以及所有朋友的帖子。
希望对您有所帮助:)