elasticsearch - Elasticsearch 总和仅根据匹配的文档ID汇总-6ren

elasticsearch - Elasticsearch 总和仅根据匹配的文档ID汇总

转载作者：行者123 更新时间：2023-12-03 01:18:41

我是Elasticsearch的新手，我的文档中有两个具有唯一ID的文档，当exceptionId为1时为exceptionId，然后正确返回文档1的总和，但是如果我想输入两个文档的总和，而我的输入为exceptionId 1和2，然后Elasticsearch将对两个文档进行求和，并在我的情况下为匹配的输入返回结果，相应的文档总和应返回，当输入为多个时，聚合应为多个。

这是映射。

{
    "mappings": {
        "recommendations": {
            "properties": {
                "events": {
                    "type": "nested",
                    "properties": {
                        "recommendationData": {
                            "type": "nested",
                            "properties": {
                                "recommendations": {
                                    "type": "nested",
                                    "properties": {
                                        "recommendationType": {
                                            "type": "keyword"
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
    }
}

这是具有exceptionId为“1”的文档

{
    "clusterId": "1",
    "rank": 1,
    "events": [
        {
            "eventId": "1",
            "eventType": "Delayed",
            "metaInfo": {
                "batch_id": "batch_1"
            },
            "recommendationData": [
                {
                    "exceptionId": "1",
                    "item": "KitKat",
                    "location": "DC1",
                    "dueDate": "2019-01-10T05:30:00.000+0530",
                    "quantity": 100,
                    "metaInfo": {
                        "batch_id": "batch_1",
                        "dummy_id": "dummy_1"
                    },
                    "rank": 1,
                    "recommendations": [
                        {
                            "rank": 1,
                            "recommendationType": "Out Of Stock",
                            "customerName": "Walmart",
                            "stockTransfer": {
                                "primaryRecommendation": true,
                                "priority": 1,
                                "sourceLocation": "DC1",
                                "transferQuantity": 100,
                                "metaInfo": 40,
                                "shipDate": "01/01/2020",
                                "arrivalDate": "10/01/2020",
                                "transportMode": "Air",
                                "transferCost": 1000,
                                "maxQtyAvailableForTransfer": 40,
                                "totalQtyAtSource": 1,
                                "revenueRecovered": 12000
                            },
                            "expedite": null
                        }
                    ]
                }
            ]
        }
    ]
}

这是具有exceptionId为“2”的文档

{
    "clusterId": "2",
    "rank": 2,
    "events": [
        {
            "eventId": "2",
            "eventType": "Delayed",
            "metaInfo": {
                "batch_id": "batch_1"
            },
            "recommendationData": [
                {
                    "exceptionId": "2",
                    "item": "KitKat",
                    "location": "DC1",
                    "dueDate": "2019-01-10T05:30:00.000+0530",
                    "quantity": 100,
                    "metaInfo": {
                        "batch_id": "batch_1",
                        "dummy_id": "dummy_1"
                    },
                    "rank": 1,
                    "recommendations": [
                        {
                            "rank": 1,
                            "recommendationType": "Out Of Stock",
                            "customerName": "Walmart",
                            "stockTransfer": {
                                "primaryRecommendation": true,
                                "priority": 1,
                                "sourceLocation": "DC1",
                                "transferQuantity": 100,
                                "metaInfo": 40,
                                "shipDate": "01/01/2020",
                                "arrivalDate": "10/01/2020",
                                "transportMode": "Air",
                                "transferCost": 1000,
                                "maxQtyAvailableForTransfer": 40,
                                "totalQtyAtSource": 1,
                                "revenueRecovered": 12000
                            },
                            "expedite": null
                        }
                    ]
                }
            ]
        }
    ]
}

这是我尝试过的查询

{
    "aggregations": {
        "recommendations": {
            "nested": {
                "path": "events.recommendationData"
            },
            "aggregations": {
                "exceptionId": {
                    "filter": {
                        "terms": {
                            "events.recommendationData.exceptionId": [
                                "1", "2"
                            ],
                            "boost": 1
                        }
                    },
                    "aggregations": {
                        "by_item": {
                            "terms": {
                                "field": "events.recommendationData.item.keyword",
                                "size": 10,
                                "min_doc_count": 1,
                                "shard_min_doc_count": 0,
                                "show_term_doc_count_error": false,
                                "order": [
                                    {
                                        "_count": "desc"
                                    },
                                    {
                                        "_key": "asc"
                                    }
                                ]
                            },
                            "aggregations": {
                                "by_destination": {
                                    "terms": {
                                        "field": "events.recommendationData.location.keyword",
                                        "size": 10,
                                        "min_doc_count": 1,
                                        "shard_min_doc_count": 0,
                                        "show_term_doc_count_error": false,
                                        "order": [
                                            {
                                                "_count": "desc"
                                            },
                                            {
                                                "_key": "asc"
                                            }
                                        ]
                                    },
                                    "aggregations": {
                                        "recommendations": {
                                            "nested": {
                                                "path": "events.recommendationData.recommendations"
                                            },
                                            "aggregations": {
                                                "by_trans": {
                                                    "terms": {
                                                        "field": "events.recommendationData.recommendations.stockTransfer.transportMode.keyword",
                                                        "size": 10,
                                                        "min_doc_count": 1,
                                                        "shard_min_doc_count": 0,
                                                        "show_term_doc_count_error": false,
                                                        "order": [
                                                            {
                                                                "_count": "desc"
                                                            },
                                                            {
                                                                "_key": "asc"
                                                            }
                                                        ]
                                                    },
                                                    "aggregations": {
                                                        "by_sourcelocation": {
                                                            "terms": {
                                                                "field": "events.recommendationData.recommendations.stockTransfer.sourceLocation.keyword",
                                                                "size": 10,
                                                                "min_doc_count": 1,
                                                                "shard_min_doc_count": 0,
                                                                "show_term_doc_count_error": false,
                                                                "order": [
                                                                    {
                                                                        "_count": "desc"
                                                                    },
                                                                    {
                                                                        "_key": "asc"
                                                                    }
                                                                ]
                                                            },
                                                            "aggregations": {
                                                                "by_shipdate": {
                                                                    "terms": {
                                                                        "field": "events.recommendationData.recommendations.stockTransfer.shipDate.keyword",
                                                                        "size": 10,
                                                                        "min_doc_count": 1,
                                                                        "shard_min_doc_count": 0,
                                                                        "show_term_doc_count_error": false,
                                                                        "order": [
                                                                            {
                                                                                "_count": "desc"
                                                                            },
                                                                            {
                                                                                "_key": "asc"
                                                                            }
                                                                        ]
                                                                    },
                                                                    "aggregations": {
                                                                        "by_arrival": {
                                                                            "terms": {
                                                                                "field": "events.recommendationData.recommendations.stockTransfer.arrivalDate.keyword",
                                                                                "size": 10,
                                                                                "min_doc_count": 1,
                                                                                "shard_min_doc_count": 0,
                                                                                "show_term_doc_count_error": false,
                                                                                "order": [
                                                                                    {
                                                                                        "_count": "desc"
                                                                                    },
                                                                                    {
                                                                                        "_key": "asc"
                                                                                    }
                                                                                ]
                                                                            },
                                                                            "aggregations": {
                                                                                "quantity": {
                                                                                    "sum": {
                                                                                        "field": "events.recommendationData.recommendations.stockTransfer.transferQuantity"
                                                                                    }
                                                                                },
                                                                                "transfercost": {
                                                                                    "sum": {
                                                                                        "field": "events.recommendationData.recommendations.stockTransfer.transferCost"
                                                                                    }
                                                                                },
                                                                                "revenueRecovered": {
                                                                                    "sum": {
                                                                                        "field": "events.recommendationData.recommendations.stockTransfer.revenueRecovered"
                                                                                    }
                                                                                }
                                                                            }
                                                                        }
                                                                    }
                                                                }
                                                            }
                                                        }
                                                    }
                                                }
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
    }
}

这是这里的输出，它正在对文档1和文档2进行所有求和

       {
    "took": 3,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": 2,
        "max_score": 0.0,
        "hits": []
    },
    "aggregations": {
        "recommendations": {
            "doc_count": 2,
            "exceptionId": {
                "doc_count": 2,
                "by_item": {
                    "doc_count_error_upper_bound": 0,
                    "sum_other_doc_count": 0,
                    "buckets": [
                        {
                            "key": "KitKat",
                            "doc_count": 2,
                            "by_destination": {
                                "doc_count_error_upper_bound": 0,
                                "sum_other_doc_count": 0,
                                "buckets": [
                                    {
                                        "key": "DC1",
                                        "doc_count": 2,
                                        "recommendations": {
                                            "doc_count": 2,
                                            "by_trans": {
                                                "doc_count_error_upper_bound": 0,
                                                "sum_other_doc_count": 0,
                                                "buckets": [
                                                    {
                                                        "key": "Air",
                                                        "doc_count": 2,
                                                        "by_sourcelocation": {
                                                            "doc_count_error_upper_bound": 0,
                                                            "sum_other_doc_count": 0,
                                                            "buckets": [
                                                                {
                                                                    "key": "DC1",
                                                                    "doc_count": 2,
                                                                    "by_shipdate": {
                                                                        "doc_count_error_upper_bound": 0,
                                                                        "sum_other_doc_count": 0,
                                                                        "buckets": [
                                                                            {
                                                                                "key": "01/01/2020",
                                                                                "doc_count": 2,
                                                                                "by_arrival": {
                                                                                    "doc_count_error_upper_bound": 0,
                                                                                    "sum_other_doc_count": 0,
                                                                                    "buckets": [
                                                                                        {
                                                                                            "key": "10/01/2020",
                                                                                            "doc_count": 2,
                                                                                            "quantity": {
                                                                                                "value": 200.0
                                                                                            },
                                                                                            "transfercost": {
                                                                                                "value": 2000.0
                                                                                            },
                                                                                            "revenueRecovered": {
                                                                                                "value": 24000.0
                                                                                            }
                                                                                        }
                                                                                    ]
                                                                                }
                                                                            }
                                                                        ]
                                                                    }
                                                                }
                                                            ]
                                                        }
                                                    }
                                                ]
                                            }
                                        }
                                    }
                                ]
                            }
                        }
                    ]
                }
            }
        }
    }
}

最佳答案

据我对您的要求的理解，您需要在“exceptionId”上进行术语汇总
让我知道这是否适合您
查询:

{
  "aggregations": {
    "recommendations": {
      "nested": {
        "path": "events.recommendationData"
      },
      "aggregations": {
        "exceptionId": {
          "filter": {
            "terms": {
              "events.recommendationData.exceptionId": [
                "1",
                "2"
              ],
              "boost": 1
            }
          },
          "aggregations": {
            "exceptionId": {
              "terms": {
                "field": "events.recommendationData.exceptionId.keyword",
                "size": 10
              },
              "aggregations": {
                "by_item": {
                  "terms": {
                    "field": "events.recommendationData.item.keyword",
                    "size": 10,
                    "min_doc_count": 1,
                    "shard_min_doc_count": 0,
                    "show_term_doc_count_error": false,
                    "order": [
                      {
                        "_count": "desc"
                      },
                      {
                        "_key": "asc"
                      }
                    ]
                  },
                  "aggregations": {
                    "by_destination": {
                      "terms": {
                        "field": "events.recommendationData.location.keyword",
                        "size": 10,
                        "min_doc_count": 1,
                        "shard_min_doc_count": 0,
                        "show_term_doc_count_error": false,
                        "order": [
                          {
                            "_count": "desc"
                          },
                          {
                            "_key": "asc"
                          }
                        ]
                      },
                      "aggregations": {
                        "recommendations": {
                          "nested": {
                            "path": "events.recommendationData.recommendations"
                          },
                          "aggregations": {
                            "by_trans": {
                              "terms": {
                                "field": "events.recommendationData.recommendations.stockTransfer.transportMode.keyword",
                                "size": 10,
                                "min_doc_count": 1,
                                "shard_min_doc_count": 0,
                                "show_term_doc_count_error": false,
                                "order": [
                                  {
                                    "_count": "desc"
                                  },
                                  {
                                    "_key": "asc"
                                  }
                                ]
                              },
                              "aggregations": {
                                "by_sourcelocation": {
                                  "terms": {
                                    "field": "events.recommendationData.recommendations.stockTransfer.sourceLocation.keyword",
                                    "size": 10,
                                    "min_doc_count": 1,
                                    "shard_min_doc_count": 0,
                                    "show_term_doc_count_error": false,
                                    "order": [
                                      {
                                        "_count": "desc"
                                      },
                                      {
                                        "_key": "asc"
                                      }
                                    ]
                                  },
                                  "aggregations": {
                                    "by_shipdate": {
                                      "terms": {
                                        "field": "events.recommendationData.recommendations.stockTransfer.shipDate.keyword",
                                        "size": 10,
                                        "min_doc_count": 1,
                                        "shard_min_doc_count": 0,
                                        "show_term_doc_count_error": false,
                                        "order": [
                                          {
                                            "_count": "desc"
                                          },
                                          {
                                            "_key": "asc"
                                          }
                                        ]
                                      },
                                      "aggregations": {
                                        "by_arrival": {
                                          "terms": {
                                            "field": "events.recommendationData.recommendations.stockTransfer.arrivalDate.keyword",
                                            "size": 10,
                                            "min_doc_count": 1,
                                            "shard_min_doc_count": 0,
                                            "show_term_doc_count_error": false,
                                            "order": [
                                              {
                                                "_count": "desc"
                                              },
                                              {
                                                "_key": "asc"
                                              }
                                            ]
                                          },
                                          "aggregations": {
                                            "quantity": {
                                              "sum": {
                                                "field": "events.recommendationData.recommendations.stockTransfer.transferQuantity"
                                              }
                                            },
                                            "transfercost": {
                                              "sum": {
                                                "field": "events.recommendationData.recommendations.stockTransfer.transferCost"
                                              }
                                            },
                                            "revenueRecovered": {
                                              "sum": {
                                                "field": "events.recommendationData.recommendations.stockTransfer.revenueRecovered"
                                              }
                                            }
                                          }
                                        }
                                      }
                                    }
                                  }
                                }
                              }
                            }
                          }
                        }
                      }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

结果:

"aggregations" : {
    "recommendations" : {
      "doc_count" : 1,
      "exceptionId" : {
        "doc_count" : 1,
        "exceptionId" : {
          "doc_count_error_upper_bound" : 0,
          "sum_other_doc_count" : 0,
          "buckets" : [
            {
              "key" : "1",
              "doc_count" : 1,
              "by_item" : {
                "doc_count_error_upper_bound" : 0,
                "sum_other_doc_count" : 0,
                "buckets" : [
                  {
                    "key" : "KitKat",
                    "doc_count" : 1,
                    "by_destination" : {
                      "doc_count_error_upper_bound" : 0,
                      "sum_other_doc_count" : 0,
                      "buckets" : [
                        {
                          "key" : "DC1",
                          "doc_count" : 1,
                          "recommendations" : {
                            "doc_count" : 1,
                            "by_trans" : {
                              "doc_count_error_upper_bound" : 0,
                              "sum_other_doc_count" : 0,
                              "buckets" : [
                                {
                                  "key" : "Air",
                                  "doc_count" : 1,
                                  "by_sourcelocation" : {
                                    "doc_count_error_upper_bound" : 0,
                                    "sum_other_doc_count" : 0,
                                    "buckets" : [
                                      {
                                        "key" : "DC1",
                                        "doc_count" : 1,
                                        "by_shipdate" : {
                                          "doc_count_error_upper_bound" : 0,
                                          "sum_other_doc_count" : 0,
                                          "buckets" : [
                                            {
                                              "key" : "01/01/2020",
                                              "doc_count" : 1,
                                              "by_arrival" : {
                                                "doc_count_error_upper_bound" : 0,
                                                "sum_other_doc_count" : 0,
                                                "buckets" : [
                                                  {
                                                    "key" : "10/01/2020",
                                                    "doc_count" : 1,
                                                    "quantity" : {
                                                      "value" : 100.0
                                                    },
                                                    "transfercost" : {
                                                      "value" : 1000.0
                                                    },
                                                    "revenueRecovered" : {
                                                      "value" : 12000.0
                                                    }
                                                  }
                                                ]
                                              }
                                            }
                                          ]
                                        }
                                      }
                                    ]
                                  }
                                }
                              ]
                            }
                          }
                        }
                      ]
                    }
                  }
                ]
              }
            }
          ]
        }
      }
    }
  }

关于elasticsearch - Elasticsearch 总和仅根据匹配的文档ID汇总，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/61377814/

文章推荐： wpf - WPF和WinForms可以在应用程序中混合使用吗？

文章推荐： powershell - 在PowerShell中为findstr/grep输出着色

文章推荐： c# - powershell cmdlet的动态输出类型？

awk - 如果行与“foo”匹配，线上方与“bar”匹配，线下方与“baz”匹配，则删除行？
使用sed和/或awk，仅在行包含字符串“ foo”并且行之前和之后的行分别包含字符串“ bar”和“ baz”时，我才希望删除行。因此，对于此输入： blah blah foo blah bar
c# - 如何按 X% 匹配 2 个字符串(即 >90% 匹配)
例如: S1: "some filename contains few words.txt" S2:“一些文件名包含几个单词 - draft.txt” S3:“一些文件名包含几个单词 - 另一个 dr
R 合并数据帧，允许不精确的 ID 匹配(例如，附加字符 1234 匹配 ab1234)
我正在尝试处理一些非常困惑的数据。我需要通过样本 ID 合并两个包含不同类型数据的大数据框。问题是一张表的样本 ID 有许多不同的格式，但大多数都包含用于匹配其 ID 中某处所需的 ID 字符串，例如
css - 匹配 col-md 时显示 div，匹配 col-sm 时不显示
我想在匹配特定屏幕尺寸时显示特定图像。在这种情况下，对于 Bootstrap ，我使用 col-xx-## 作为我的选择。但似乎它并没有真正按照我认为应该的方式工作。基本思路，我想显示一种全屏图像，
apache - mod_rewrite 问题 : RewriteCond %{REQUEST_FILENAME} ! -f 匹配，即使 REQUEST_FILENAME 不应(完全)匹配
出于某种原因，这条规则 RewriteCond %{REQUEST_FILENAME} !-f RewriteCond %{REQUEST_FILENAME} !-d RewriteRule ^(.*
F# 匹配 ->
我想做类似的东西(Nemerle 语法) def something = match(STT) | 1 with st= "Summ" | 2 with st= "AVG" =>
JavaScript 匹配
假设这是我的代码 var str="abc=1234587;abc=19855284;abc=1234587;abc=19855284;abc=1234587;abc=19855284;abc=123
JavaScript 匹配
我怎样才能得到这个字符串的数字:'(31.5393701, -82.46235569999999)' 我已经在尝试了，但这离解决方案还很远:) text.match(/$(\d+),(\d+)$/
JavaScript 匹配
如何去除输出中的逗号 (,)？有没有更好的方法从字符串或句子中搜索 url。 alert(" http://www.cnn.com df".match(/https?:\/\/([-\w\.]+
Python - 匹配
a = ('one', 'two') b = ('ten', 'ten') z = [('four', 'five', 'six'), ('one', 'two', 'twenty')] 我正在尝试
vba - 循环遍历行和列时的索引/匹配
我已经编写了以下代码，我希望用它来查找从第 21 列到另一张表中最后一行的值，并根据这张表中 A 列和另一张表中 B 列中的值将它们返回到这张表床单。当我使用下面的代码时，我得到一个工作表错误。你能
Excel 匹配 IF 语句未正确评估
我在以下结构中有两列 A B 1 49 4922039670 我已经能够评估 =LEN(A1)如2 , =LEFT(B1,2)如49 , 和 =LEFT(B1,LEN(A1)
基于行首的 Vim 匹配
我有一个文件，其中一行可以以 + 开头, -或 * .在其中一些行之间可以有以字母或数字(一般文本)开头的行(也包含这些字符，但不在第 1 列中!)。知道这一点，设置匹配和突出显示机制的最简单方法是
正则表达式:匹配，但如果在评论中则不匹配
我有一个数据字段文件，其中可能包含注释，如下所示: id, data, data, data 101 a, b, c 102 d, e, f 103 g, h, i // has to do with
匹配 url 的正则表达式模式
我有以下模式:/^\/(?P.+)$/匹配:/url . 我的问题是它也匹配 /url/page ，如何忽略/在这个正则表达式中？该模式应该: 模式匹配:/url 模式不匹配:/url/page 提
r - R中多维度的聚类/匹配
我有一个非常庞大且复杂的数据集，其中包含许多对公司的观察。公司的一些观察是多余的，我需要制作一个键来将多余的观察映射到一个单独的观察。然而，判断他们是否真的代表同一家公司的唯一方法是通过各种变量的相似
xpath 匹配 - 查找值不在值集中的标签是否存在
我有以下 XML A B C 我想查找 if not(exists(//Record/subRecord
javascript - 匹配/不匹配的正则表达式上没有出现警报框？
我制作了一个正则表达式来验证潜在的比特币地址，现在当我单击报价按钮时，我希望根据正则表达式检查表单中输入的值，但它不起作用。 https://jsfiddle.net/arkqdc8a/5/ var
sql - 检查支架是否平衡/匹配
我有一些 MS Word 文档，我已将其全部内容转移到 SQL 表中。内容包含多个方括号和大括号，例如 [{a} as at [b],] {c,} {d,} etc 我需要进行检查以确保括号平衡/匹
JavaScript Unicode 匹配
我正在使用 Node.js 从 XML 文件读取数据。但是当我尝试将文件中的数据与文字进行比较时，它不匹配，即使它看起来相同: const parser: xml2js.Parser = new

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

elasticsearch - Elasticsearch 总和仅根据匹配的文档ID汇总