arrays - Elasticsearch:当字段是数组时如何按字段分组文档-6ren

arrays - Elasticsearch:当字段是数组时如何按字段分组文档

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

我的Elasticsearch索引如下所示:

{
    "team": ["Jane","Jason"],
    "date": "2020/07/23 12:00:56",
    "is_work_done": true
},
{
    "team": ["Jane","Jason"],
    "date": "2020/07/22 14:23:56",
    "is_work_done": false
},
{
    "team": ["Jane","Jason","Anna"],
    "date": "2020/07/17 09:22:10",
    "is_work_done": false
},
{
    "team": ["Alex","George","Anna"],
    "date": "2020/07/13 03:24:19",
    "is_work_done": true
}

我的映射是:

{
  "mappings": {
    "type_name": {
      "properties": {
        "team":    { "type": "keyword" },  
        "date":  {"type": "date", "format": "yyyy/MM/dd HH:mm:ss"},
        "is_work_done": { "type": "boolean" }
      }
    }
  }
}

我想收集有关每个团队的信息。如何按团队对文档进行分组？
我创建此索引来解决此问题，因为实际上，我不知道每个团队包含多少成员。
我试图汇总文档，但是找不到适合的汇总类型。
例如，使用以下查询:

GET /testbench-test/_search
{
  "aggs": {
    "mybucket": {
      "terms": { "field": "team" } 
    }
  }
}

我得到这个结果:

 "aggregations" : {
    "mybucket" : {
      "doc_count_error_upper_bound" : 0,
      "sum_other_doc_count" : 0,
      "buckets" : [
        {
          "key" : "Jane",
          "doc_count" : 3
        },
        {
          "key" : "Jason",
          "doc_count" : 3
        },
        {
          "key" : "Anna",
          "doc_count" : 2
        },
        {
          "key" : "Alex",
          "doc_count" : 1
        },
        {
          "key" : "George",
          "doc_count" : 1
        }
      ]
    }
  }

感谢您的帮助!
编辑:
通过对包含64,030个索引的真实索引的查询:

POST _search 
{
  "aggs": {
    "teams": {
      "terms": {
        "script": "doc['team'].join(' & ')",
        "size": 10
      }
    }
  }
}

我得到这个结果:

{
  "took" : 52,
  "timed_out" : false,
  "_shards" : {
    "total" : 5,
    "successful" : 5,
    "skipped" : 0,
    "failed" : 0
  },
  "hits" : {
    "total" : 64031,
    "max_score" : 1.0,
    "hits" : [
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "98",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "9827af",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f930813",
          "date" : "2019/04/25 11:40:19",
          "duration" : 0.9953742847,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00013A9D00002"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "b0c9a8aa4",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "b0c9a1be0a8aa4",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf385a1562d78813",
          "date" : "2019/04/29 08:08:37",
          "duration" : 0.4976871423,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00149"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "bb1d525e2a368f6d4",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "bb1da368f6d4",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f85a1562d78813",
          "date" : "2019/04/29 08:09:51",
          "duration" : 0.5208305083,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00179"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "87bec43ce2553c590b",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "87bec43c-e2553c590b",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f9302bcdf8c26e1f85a1562d78813",
          "date" : "2019/04/29 08:10:10",
          "duration" : 0.4629604518,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00181"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "3499224bdac4fa39",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "349922444bdac4fa39",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6e1f85a1562d78813",
          "date" : "2019/04/29 08:10:49",
          "duration" : 0.5092588253,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "uut" : [
            "MCANT00009A9D00171"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "f8236de0-dd6a97b7a81",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "f8236de0-add6a97b7a81",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f93085a1562d78813",
          "date" : "2019/04/29 09:51:47",
          "duration" : 0.6134272553,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00221"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "339fa5a2e-cf9f1f4738bf",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "339fa5a9f1f4738bf",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f932d78813",
          "date" : "2019/04/29 09:51:57",
          "duration" : 0.6249989383,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00185"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "dbd45ec4-f53b-4bda-9eeb-dadf2e3ab366",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "dbd45ec4-f53b-4bda-9eeb-dadf2e3ab366",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f9302bcdfd78813",
          "date" : "2019/04/29 09:52:19",
          "duration" : 0.5787005648,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00184"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "bc0d3548bed68",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "bc0d354348bed68",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf3801562d78813",
          "date" : "2019/04/29 08:08:12",
          "duration" : 0.5208305083,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00160"
          ]
        }
      },
      {
        "_index" : "test-logs",
        "_type" : "log",
        "_id" : "d591b9e7-683a-4d78-be31-1b137b8a3b2b",
        "_score" : 1.0,
        "_source" : {
          "uuid" : "d591b9e7-683a-4d78-be31-1b137b8a3b2b",
          "benchId" : "m",
          "benchGroup" : "e",
          "machine" : "CH",
          "sha1" : "ddf380fd6a2f93013",
          "date" : "2019/04/29 08:08:05",
          "duration" : 0.6828689948,
          "isCss" : false,
          "isPassed" : true,
          "finalStatus" : "OK_VNA_TEST",
          "team" : [
            "MCANT00009A9D00146"
          ]
        }
      }
    ]
  },
  "aggregations" : {
    "teams" : {
      "doc_count_error_upper_bound" : 25,
      "sum_other_doc_count" : 63658,
      "buckets" : [
        {
          "key" : "SI050010AA8C00001",
          "doc_count" : 86
        },
        {
          "key" : "00845D9E0137 & 00851F9E0095 & CPPCB00608C9F00060 & MCSAS00676A9F00141_-27.8_B & MCSAS00677A9F00146_23.0_B & SI050012AG9F00060",
          "doc_count" : 56
        },
        {
          "key" : "00845D9E0275 & 00851F9G0056 & CPPCB00608C9F00127 & MCSAS00676B9G00012 & MCSAS00676B9G00012_-21.2_C & MCSAS00677B9G00005 & MCSAS00677B9G00005_32.5_C & SI050012AG9F00127",
          "doc_count" : 43
        },
        {
          "key" : "00844G9D0041 & 00847D9G0020 & MCANT00009A9G00048 & MCSAS00652F9E00091 & S20-17272 & SI050001AG9G00055 & SI050004AA9F00059",
          "doc_count" : 39
        },
        {
          "key" : "00845D9E0035 & 00851F9E0062 & CPPCB00608C9E00034 & MCSAS00676A9E00090_-35.0_B & MCSAS00677A9E00089_31.0_B & SI050012AG9E00034",
          "doc_count" : 34
        },
        {
          "key" : "IX & IX-c2-67063 & IX-x2-00511 & SI050010AA9A00002 & droneProduction",
          "doc_count" : 27
        },
        {
          "key" : "IX & IX-12-10251 & IX-x2-00484 & SI050001AF9A00020 & SI050010AA8J00154 & SI050012AG9D00082 & droneClient",
          "doc_count" : 25
        },
        {
          "key" : "MCANT00009A9G00048 & MCSAS00652F9E00091 & S20-17272 & SI050001AG9G00055",
          "doc_count" : 24
        },
        {
          "key" : "00883C0F0000",
          "doc_count" : 20
        },
        {
          "key" : "00844C8B0029 & 00847C8E0018 & 00849A8B0015 & MCANT00009A8E00017 & N/A & S20-00533 & SI050002AA8E000001 & SI050004AA8E000514",
          "doc_count" : 19
        }
      ]
    }
  }
}

为什么所有不同的“团队”都不拥有自己的水桶？

最佳答案

您可以做的是在术语聚合中使用一个脚本，如下所示:

POST teams/_search 
{
  "size": 0,
  "aggs": {
    "teams": {
      "terms": {
        "script": "doc['team'].join('-')",
        "size": 10
      }
    }
  }
}

您将得到的结果是这样的:

  "buckets" : [
    {
      "key" : "Jane-Jason",
      "doc_count" : 2
    },
    {
      "key" : "Alex-Anna-George",
      "doc_count" : 1
    },
    {
      "key" : "Anna-Jane-Jason",
      "doc_count" : 1
    }
  ]

关于arrays - Elasticsearch:当字段是数组时如何按字段分组文档，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/63054144/

文章推荐： javascript - Postal.js 订阅未接收来自其他 React 组件的帖子

文章推荐： java - Azure 托管 cassandra 集群公共(public) IP

文章推荐： azure - 如何使用 Powershell 从 csv 文件中仅读取一列

android - 当我们使用 SQLite 时，当我们使用 content provider 时，当我们使用 Shared preference 时
SQLite、Content provider 和 Shared Preference 之间的所有已知区别。但我想知道什么时候需要根据情况使用 SQLite 或 Content Provider 或
Backbone.js 模型验证仅在 set->save 时(不是在 fetch 时)
警告:我正在使用一个我无法完全控制的后端，所以我正在努力解决 Backbone 中的一些注意事项，这些注意事项可能在其他地方更好地解决......不幸的是，我别无选择，只能在这里处理它们! 所以，我的
jquery - 使用 “prefetch” 时 Twitter 预输入没有结果，但使用 “remote” JSON 时
我一整天都在挣扎。我的预输入搜索表达式与远程 json 数据完美配合。但是当我尝试使用相同的 json 数据作为预取数据时，建议为空。点击第一个标志后，我收到预定义消息“无法找到任何内容...”，结果
java - repaint() 时 JTextArea 不显示，但 revalidate() 时 Graphics 不更新？
我正在制作一个模拟 NHL 选秀彩票的程序，其中屏幕右侧应该有一个 JTextField，并且在左侧绘制弹跳的选秀球。我创建了一个名为 Ball 的类，它实现了 Runnable，并在我的主 Draf
java - java中将时间戳转换为特定格式(年、月、周、日、时、时、分、秒)
这个问题已经有答案了: How can I calculate a time span in Java and format the output? (18 个回答) 已关闭 9 年前。这是我的代码
设置 header 时 AJAX 请求失败，但没有设置 header 时 AJAX 请求会成功
我有一个 ASP.NET Web API 应用程序在我的本地 IIS 实例上运行。 Web 应用程序配置有 CORS。我调用的 Web API 方法类似于: [POST("/API/{foo}/{ba
android - 用户输入年、月、日、时、分与系统年、月、日、时、分的区别
我将用户输入的时间和日期作为: DatePicker dp = (DatePicker) findViewById(R.id.datePicker); TimePicker tp = (TimePic
algorithm - 在处理 Tabu Search Optimization 时，当所有相邻解决方案都是 tabu 时，通常的做法是什么？
放宽“邻居”的标准是否足够，或者是否有其他标准行动可以采取？最佳答案如果所有相邻解决方案都是 Tabu，则听起来您的 Tabu 列表的大小太长或您的释放策略太严格。一个好的 Tabu 列表长度是
c++ - 为什么我需要传递一个比较器来构造一个 priority_queue，当它是 lambda 时，而不是当它是 std::greater 时？
我正在阅读来自 cppreference 的代码示例: #include #include #include #include template void print_queue(T& q)
javascript - 当触发器为 'click' 时，Bootstrap 3 工具提示表现得很奇怪，当触发器为 'manual' 时，则不起作用
我快疯了，我试图理解工具提示的行为，但没有成功。 1. 第一个问题是当我尝试通过插件(按钮 1)在点击事件中使用它时 -> 如果您转到 Fiddle，您会在“内容”内看到该函数' 每次点击都会调用该属
javascript - 使用 useContext 时，数据首先加载为空数组，当我应用 .map() 或 .find() 时，我收到一条错误消息
我在功能组件中有以下代码: const [ folder, setFolder ] = useState([]); const folderData = useContext(FolderContex
swift - 使用 NSURLSession 时 GET 成功，但使用 AFHTTPSessionManager 时 GET 失败
我在使用预签名网址和 AFNetworking 3.0 从 S3 获取图像时遇到问题。我可以使用 NSMutableURLRequest 和 NSURLSession 获取图像，但是当我使用 AFHT
java - 当池生命周期为 LIFE_CYCLE_FAILED 时，使用 UCP 管理器调用 closeConnections() 时 UCP 连接是否关闭？
我正在使用 Oracle ojdbc 12 和 Java 8 处理 Oracle UCP 管理器的问题。当 UCP 池启动失败时，我希望关闭它创建的连接。当池初始化期间遇到 ORA-02391:超过
ios - 当我点击 "Run"时，应用程序崩溃，但是当我点击 "Stop"然后 "Run"时，应用程序崩溃
关闭。此题需要details or clarity 。目前不接受答案。想要改进这个问题吗？通过 editing this post 添加详细信息并澄清问题. 已关闭 9 年前。 Improve
css - 我有一个笨蛋。当我在全局范围内定义我的 css 时，它起作用了。当我在我的组件中定义我的 css 时，它失败了。这是怎么回事？
引用这个plunker: https://plnkr.co/edit/GWsbdDWVvBYNMqyxzlLY?p=preview 我在 styles.css 文件和 src/app.ts 文件中指定
python - 当宽度 <1.0 时，Matplotlib 周线太细；当宽度>=1.0 时，周线太粗
为什么我的条形这么细？我尝试将宽度设置为 1，它们变得非常厚。我不知道还能尝试什么。默认厚度为 0.8，这是应该的样子吗？ import matplotlib.pyplot as plt import
当我使用 RIGHT JOIN 时，MYSQL 无法识别字段，但当我使用 NATURAL JOIN 时，MYSQL 可以识别字段
当我编写时，查询按预期执行: SELECT id, day2.count - day1.count AS diff FROM day1 NATURAL JOIN day2; 但我真正想要的是右连接。当
python - 在 pandas 中读取时间值(时、分、秒、日、月、年)时，如何指定先到先得？
我有以下时间数据: 0 08/01/16 13:07:46,335437 1 18/02/16 08:40:40,565575 2 14/01/16 22:2
javascript - 当我使用 axios POST 时，Req.body 为空，但当我使用 'request' 时，它工作正常
一些背景知识 -我的 NodeJS 服务器在端口 3001 上运行，我的 React 应用程序在端口 3000 上运行。我在 React 应用程序 package.json 中设置了一个代理来代理对端
javascript - 使用 AngularJs 时，当 img 标签具有 src attr 时，如何在其上设置 data-src
我面临着一个愚蠢的问题。我试图在我的 Angular 应用程序中延迟加载我的图像，我已经尝试过这个2: 但是他们都设置了 src attr 而不是 data-src，我在这里遗漏了什么吗？保留 d

行者123

个人简介

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

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

arrays - Elasticsearch:当字段是数组时如何按字段分组文档