Sum Aggregation

单值度量标准聚合,用于汇总从聚合文档中提取的数值。可以从文档中的特定数字字段提取这些值,也可以通过提供的脚本生成这些值。

假设数据由代表销售记录的文件组成,我们可以将所有帽子的销售价格加起来:

  1. POST /sales/_search?size=0
  2. {
  3. "query" : {
  4. "constant_score" : {
  5. "filter" : {
  6. "match" : { "type" : "hat" }
  7. }
  8. }
  9. },
  10. "aggs" : {
  11. "hat_prices" : { "sum" : { "field" : "price" } }
  12. }
  13. }

响应:

  1. {
  2. ...
  3. "aggregations": {
  4. "hat_prices": {
  5. "value": 450.0
  6. }
  7. }
  8. }

聚合的名称(上面的hat_prices)也可以作为从返回的响应中检索聚合结果的密钥。

Script

我们还可以使用脚本来获取销售价格:

  1. POST /sales/_search?size=0
  2. {
  3. "query" : {
  4. "constant_score" : {
  5. "filter" : {
  6. "match" : { "type" : "hat" }
  7. }
  8. }
  9. },
  10. "aggs" : {
  11. "hat_prices" : {
  12. "sum" : {
  13. "script" : {
  14. "source": "doc.price.value"
  15. }
  16. }
  17. }
  18. }
  19. }

这将使用无痛脚本语言并且没有脚本参数将脚本参数解释为内联脚本。要使用存储的脚本,请使用以下语法:

  1. POST /sales/_search?size=0
  2. {
  3. "query" : {
  4. "constant_score" : {
  5. "filter" : {
  6. "match" : { "type" : "hat" }
  7. }
  8. }
  9. },
  10. "aggs" : {
  11. "hat_prices" : {
  12. "sum" : {
  13. "script" : {
  14. "id": "my_script",
  15. "params" : {
  16. "field" : "price"
  17. }
  18. }
  19. }
  20. }
  21. }
  22. }

Value Script

也可以使用_value从脚本访问字段值。例如,这将总和所有帽子的价格的平方:

  1. POST /sales/_search?size=0
  2. {
  3. "query" : {
  4. "constant_score" : {
  5. "filter" : {
  6. "match" : { "type" : "hat" }
  7. }
  8. }
  9. },
  10. "aggs" : {
  11. "square_hats" : {
  12. "sum" : {
  13. "field" : "price",
  14. "script" : {
  15. "source": "_value * _value"
  16. }
  17. }
  18. }
  19. }
  20. }

Missing value

缺少的参数定义了应该如何处理缺少值的文档。默认情况下,丢失该值的文档将被忽略,但也可以将它们视为具有值。例如,这将所有帽子销售视为100而不是价格。

  1. POST /sales/_search?size=0
  2. {
  3. "query" : {
  4. "constant_score" : {
  5. "filter" : {
  6. "match" : { "type" : "hat" }
  7. }
  8. }
  9. },
  10. "aggs" : {
  11. "hat_prices" : {
  12. "sum" : {
  13. "field" : "price",
  14. "missing": 100
  15. }
  16. }
  17. }
  18. }