Elasticsearch 多索引查询

Question

我有一个存储课程详细信息的索引（为简洁起见，我截断了一些属性）：

{
  "settings": {
    "index": {
      "number_of_replicas": "1",
      "number_of_shards": "1"
    }
  },
  "aliases": {
    "course": {
      
    }
  },
  "mappings": {
    "properties": {
      "name": {
        "type": "text"
      },
      "id": {
        "type": "integer"
      },
      "max_per_user": {
        "type": "integer"
      }
    }
  }
}

这里的 max_per_user 是用户可以完成课程的次数。允许用户多次通过课程但不超过课程的 max_per_user 我想跟踪用户与课程的互动。我创建了以下索引来跟踪交互事件。 event_type_id 代表一种交互方式

{
  "settings": {
    "index": {
      "number_of_replicas": "1",
      "number_of_shards": "1"
    }
  },
  "aliases": {
    "course_events": {
      
    }
  },
  "mappings": {
    "properties": {
      "user_progress": {
        "dynamic": "true",
        "properties": {
          "current_count": {
            "type": "integer"
          },
          "user_id": {
            "type": "integer"
          },
          "events": {
            "dynamic": "true",
            "properties": {
              "event_type_id": {
                "type": "integer"
              },
              "event_timestamp": {
                "type": "date",
                "format": "strict_date_time"
              }
            }
          }
        }
      },
      "created_at": {
        "type": "date",
        "format": "strict_date_time"
      },
      "course_id": {
        "type": "integer"
      }
    }
  }
}

current_count 是用户完成整个课程的次数

现在，当我在课程索引上运行搜索时，我还希望能够传入 user_id 并仅获取给定用户的 current_count 小于课程的 max_per_user 的课程

我对课程索引的搜索查询是这样的（为简洁起见，截断了一些过滤器）。这个查询是在用户搜索课程时执行的，所以基本上在执行这个时我会有user_id。

{
  "sort": [
    {
      "id": "desc"
    }
  ],
  "query": {
    "bool": {
      "filter": [
        {
          "range": {
            "end_date": {
              "gte": "2020-09-28T12:27:55.884Z"
            }
          }
        },
        {
          "range": {
            "start_date": {
              "lte": "2020-09-28T12:27:55.884Z"
            }
          }
        }
      ],
      "must": [
        {
          "term": {
            "is_active": true
          }
        }
      ]
    }
  }
}

我不确定如何构建我的搜索查询，以便能够过滤掉给定 user_id 已达到 max_per_user 的课程。

Answer 1

如果我正确理解了这个问题，您希望找到不超过 max_per_user 限制的课程。我的答案是基于相同的：

考虑到您当前的 Schema 查找所需内容的方法是：

1. 对于给定的 user_id，查找所有 course_id 及其对应的完成计数
2. 使用 #1 中获取的数据找出未超过 max_per_user 限制的课程。

问题来了：

1. 在关系数据库中，可以使用表连接和检查来解决此类用例
2. Elastic Search 不支持连接，因此无法在此处完成。

当前架构的糟糕解决方案：

1. 检查每门课程是否适用。对于 n 门课程，对 E.S 的查询数将与 N 成正比。

使用当前架构的解决方案：

1. 在用户课程完成索引（您提到的第二个索引）中，跟踪 max_per_user 并使用如下所示的简单查询来获取所需的课程 ID：

    {
     "size": 10,
     "query": {
       "script": {
          "script": "doc['current_usage'].value<doc['max_per_user'].value && 
          doc['u_id'].value==1" // <======= 1 is the user_id here
   }
   }
   }