如何进行地理距离查询仅返回我尚未“喜欢”的结果、Elastic Search、Dynamo DB

Question

我正在尝试查询我的数据库以编译给定用户喜欢/不喜欢的位置附近的帖子列表。

allPostsNearLocationUserHasLiked(
    userId: ID,
    location: LocationInput,
    radius: Int
): [Post]
allPostsNearLocationUserHasNotLiked(
    userId: ID,
    location: LocationInput,
    radius: Int
): [Post]

为此，我目前正在使用 AWSAppSync，将 dynamoDB 流式数据传输到 Elastic Search。这使我可以轻松地进行地理空间搜索并获取给定位置附近的所有帖子。

我想知道使用 dynamoDB 计算这个最有效的方法是什么？还是为我的喜欢/用户切换到 SQL 数据库更适合我？

我有一个用户、帖子和喜欢的 DynamoDB 表。我正在考虑使用管道解析器来：

1) 获取用户位置附近的所有帖子列表（弹性搜索）

2) 查询点赞表，得到我点过的所有点赞（DynamoDB）

3) 逐项合并结果。

我对这个特别是第 3 步的性能表示严重怀疑，这是一个 O(M*N) 操作。

有没有办法在 Elastic Search 中本地完成整个查询？

## DynamoDB Table?? Or maybe SQL?
type Like {
    likeId: ID!
    userId: ID!
    likedPostId: ID!
}

type Query {
    #Implement with Elastic Search
    allPostsNearLocation(location: LocationInput, radius: Int): [Post]

    ## Elastic search??? 
    allPostsNearLocationUserHasLiked(
        userId: ID,
        location: LocationInput,
        radius: Int
    ): [Post]
    allPostsNearLocationUserHasNotLiked(
        userId: ID,
        location: LocationInput,
        radius: Int
    ): [Post]
}

type Location {
    lat: Float!
    lon: Float!
}

input LocationInput {
    way: Float!
    lon: Float!
}

type Mutation {
    putPost(
        author: String!,
        title: String!,
        content: String!,
        location: LocationInput!,
        url: String!
    ): Post
    putUser(name:String): User

    likePost(userId: ID!, postId: ID!): Like
}

#DynamoDB Table
type User{
    userId: ID!
    name: String
    likes: [Like]
}

#DynamoDB table
type Post {
    id: ID!
    author: String!
    title: String!
    content: String!
    url: String!
    location: Location!
}

schema {
    query: Query
    mutation: Mutation
}

Answer 1

您最初的解决方案对我来说很有意义，尽管对延迟的担忧可能被证明是有效的。你看过relational data sources吗？目前，它仅支持 Aurora Serverless，因此您对 SQL 作为替代方案的评论将是这种情况，使用它内置于地理空间数据类型而不是 Elasticsearch 中。

您可以通过这种方式完全在 RDS 中构建架构，从而无需管道。使用连接的复杂 SQL 查询可以根据位置构建您的帖子组合，而不是通过三部分工作来完成。

Answer 2

我不确定您的性能要求是什么，但我认为您的初始计划应该没问题，如果：

1) 获取用户位置附近的所有帖子列表（弹性搜索）

这应该很快，如果 Elasticsearch 索引设置了正确的映射、大小、分片和硬件取决于数据大小。

2) 查询点赞表，获取我点过的所有点赞（DynamoDB）

这可能会很快，以防您有一个“喜欢”的内存缓存，可以是完全在内存中，也可以是惰性/LRU 缓存。

3) 逐项合并结果。

如果结果大小不是太大（使用 10-100 个项目的页面？），那么从 Elasticsearch 获取响应，在该流上运行并根据内存中的字典对其进行丰富/过滤应该没问题。

祝你好运！