1
我需要为用户和文章建模网站,其中每个用户可以用任何文章多次交互(读取,打开e.t.c)。我想通过以下嵌套映射到一个elasticsearch指数这个数据模型:索引文件的通过嵌套字段值聚合弹性搜索索引
{
"mappings": {
"user": {
"properties": {
"user_id": {"type": "string"},
"interactions": {
"type": "nested",
"properties": {
"article_id": {"type": "string"},
"interact_date": {"type": "date"}
}
}
}
}
}
}
例如:
{
"user_id": 20,
"interactions": [
{"article_id": "111", "interact_date": "2015-01-01"},
{"article_id": "111", "interact_date": "2015-01-02"},
{"article_id": "222", "interact_date": "2015-01-01"}
]
}
我需要做的数据可以聚合:
每天的互动总数,通过嵌套聚合完成:
GET /_search { "size": 0, "aggs": { "by_date": { "nested": { "path": "interactions" }, "aggs": { "m_date": {"terms": {"field": "interactions.interact_date"}} } } } }
每天唯一用户交互次数。如果特定用户与同一日期范围内的多篇文章进行交互,则用户应只计算一次。 Postgres里很简单的查询: 与3列的表[USER_ID,article_id的,interact_date]
SELECT dt, count(uid) FROM (SELECT interact_date::TIMESTAMP::DATE dt, user_id uid FROM interactions GROUP BY interact_date::TIMESTAMP::DATE, user_id) by_date GROUP BY dt;
我如何可以做同样的elasticsearch指数?
如何通过_update添加交互而不重新索引整个文档?
- 如何按特定文章过滤用户 - 仅在与某个指定文章互动时按聚合日期统计用户一次?
谢谢
谢谢@AndreiStefan。关于重新索引,我的意思是如果可以通过“安全”更新操作添加新的交互,只添加它的迭代仍然不存在。取而代之的是获取文档,在客户端进行更新并放回原处。我有很多线程为同一用户更新交互,并希望在没有分布式锁的情况下更新文档。 – Hersh
使用版本(https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html)进行更新。 –