2016-12-15 157 views
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"} 
    ] 
} 

我需要做的数据可以聚合:

  1. 每天的互动总数,通过嵌套聚合完成:

    GET /_search 
    { 
        "size": 0, 
        "aggs": { 
         "by_date": { 
          "nested": { 
           "path": "interactions" 
          }, 
          "aggs": { 
           "m_date": {"terms": {"field": "interactions.interact_date"}} 
          } 
         } 
        } 
    } 
    
  2. 每天唯一用户交互次数。如果特定用户与同一日期范围内的多篇文章进行交互,则用户应只计算一次。 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指数?

  3. 如何通过_update添加交互而不重新索引整个文档?

  4. 如何按特定文章过滤用户 - 仅在与某个指定文章互动时按聚合日期统计用户一次?

谢谢

回答

1

每天独立用户数互动。

{ 
    "size": 0, 
    "aggs": { 
    "nested_agg": { 
     "nested": { 
     "path": "interactions" 
     }, 
     "aggs": { 
     "per_day": { 
      "date_histogram": { 
      "field": "interactions.interact_date", 
      "interval": "day", 
      "min_doc_count": 1 
      }, 
      "aggs": { 
      "users_count": { 
       "reverse_nested": {}, 
       "aggs": { 
       "uniques": { 
        "cardinality": { 
        "field": "user_id" 
        } 
       } 
       } 
      } 
      } 
     } 
     } 
    } 
    } 
} 

如何通过添加互动_Update无需重新索引整个文件?

这是不可能的。这是definition of a nested object要更新,添加或删除嵌套对象,我们必须重新索引整个文档。

如何按特定文章过滤用户 - 仅在与某一指定文章进行交互时按聚合日期统计用户一次?

{ 
    "size": 0, 
    "query": { 
    "nested": { 
     "path": "interactions", 
     "query": { 
     "term": { 
      "interactions.article_id": { 
      "value": "222" 
      } 
     } 
     } 
    } 
    }, 
    "aggs": { 
    "nested_agg": { 
     "nested": { 
     "path": "interactions" 
     }, 
     "aggs": { 
     "filtered": { 
      "filter": { 
      "term": { 
       "interactions.article_id": { 
       "value": "222" 
       } 
      } 
      }, 
      "aggs": { 
      "per_day": { 
       "date_histogram": { 
       "field": "interactions.interact_date", 
       "interval": "day", 
       "min_doc_count": 1 
       }, 
       "aggs": { 
       "users_count": { 
        "reverse_nested": {}, 
        "aggs": { 
        "uniques": { 
         "cardinality": { 
         "field": "user_id" 
         } 
        } 
        } 
       } 
       } 
      } 
      } 
     } 
     } 
    } 
    } 
} 
+0

谢谢@AndreiStefan。关于重新索引,我的意思是如果可以通过“安全”更新操作添加新的交互,只添加它的迭代仍然不存在。取而代之的是获取文档,在客户端进行更新并放回原处。我有很多线程为同一用户更新交互,并希望在没有分布式锁的情况下更新文档。 – Hersh

+0

使用版本(https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html)进行更新。 –