即使字段的映射是在'text'和'keyword'类型上，如何在'sum'和'avg'aggs中进行操作？

Question

我试图对我的Elasticsearch查询执行和和AVG聚合，一切都很好，但我遇到了一个问题--我想对text/关键字类型上的嵌套字段执行前面提到的aggs。

之所以如此，是因为在执行searchAPI时，如果需要这些特定的嵌套字段和子字段，我们将使用keywords分析器。

下面是我的映射：

"eng" : {
  "type" : "nested",
  "properties" : {
    "date_updated" : {
      "type" : "long"
    },
    "soc_angry_count" : {
      "type" : "float"
    },
    "soc_comment_count" : {
      "type" : "float"
    },
    "soc_dislike_count" : {
      "type" : "float"
    },
    "soc_eng_score" : {
      "type" : "float"
    },
    "soc_er_score" : {
      "type" : "text",
      "fields" : {
        "keyword" : {
          "type" : "keyword",
          "ignore_above" : 256
        }
      }
    },
    "soc_haha_count" : {
      "type" : "float"
    },
    "soc_kf_score" : {
      "type" : "text",
      "fields" : {
        "keyword" : {
          "type" : "keyword",
          "ignore_above" : 256
        }
      }
    },
    "soc_like_count" : {
      "type" : "float"
    },
    "soc_love_count" : {
      "type" : "float"
    },
    "soc_mm_score" : {
      "type" : "float"
    },
    "soc_sad_count" : {
      "type" : "float"
    },
    "soc_save_count" : {
      "type" : "float"
    },
    "soc_share_count" : {
      "type" : "float"
    },
    "soc_te_score" : {
      "type" : "text",
      "fields" : {
        "keyword" : {
          "type" : "keyword",
          "ignore_above" : 256
        }
      }
    },
    "soc_view_count" : {
      "type" : "float"
    },
    "soc_wow_count" : {
      "type" : "float"
    }
  }
}

请关注eng嵌套字段的SOC_ER_Score、SOC_KF_Score和SOC_TE_Score子字段...

当我执行以下AGG时，它工作正常：

'aggs' => [
    'ENGAGEMENT' => [
        'nested' => [
            'path' => "eng"
        ],
        'aggs' => [
            'ARTICLES' => [
                //Use Histogram because the pub_date is of
                //long data type
                //Use interval 86400 to represent 1 day
                'histogram' => [
                    'field'  => "eng.date_updated",
                    "interval" => "86400",
                ],
                'aggs'= [
                    'SUM' => [
                        'sum' => [
                            "field" => "eng.soc_like_score"
                        ]
                    ]
                ]
            ]
        ]
    ]
]

下面是执行搜索API后的输出

但是如果查询如下所示：

'aggs' => [
    'ENGAGEMENT' => [
        'nested' => [
            'path' => "eng"
        ],
        'aggs' => [
            'ARTICLES' => [
                //Use Histogram because the pub_date is of
                //long data type
                //Use interval 86400 to represent 1 day
                'histogram' => [
                    'field'  => "eng.date_updated",
                    "interval" => "86400",
                ],
                'aggs'= [
                    'SUM' => [
                        'sum' => [
                            "field" => "eng.soc_te_score"
                        ]
                    ]
                ]
            ]
        ]
    ]
]

输出如下所示：

执行的解决方案

解决方案1（供确认）
在阅读了一些论坛讨论之后，我了解到基于Java的解析是可用的，但似乎对我来说不起作用

以下是我修改后的查询：

'aggs'= [
    'SUM' => [
        'sum' => [
            "field" => "Float.parseFloat(eng.soc_te_score).value"
        ]
    ]
]

但不幸的是，它的响应为null或0值

顺便说一句，我使用Laravel作为我的Web框架，这就是为什么我的调试器或错误消息窗口是这样的

请求您的帮助，请提前感谢您！

Answer 1

我将创建另一个数字子字段除了关键字一。因此，可以使用关键字字段进行搜索，使用数字字段进行聚合。

例如，像这样修改映射：

"soc_er_score" : {
  "type" : "text",
  "fields" : {
    "keyword" : {
      "type" : "keyword",
      "ignore_above" : 256
    },
    "numeric" : {
      "type" : "long",
      "ignore_malformed": true
    }
  }
},

然后可以使用：

• soc_er_score进行全文搜索
• soc_er_score.keyword用于排序、术语聚合和精确匹配
soc_er_score.numeric用于 sum和其他度量聚合。

如果索引中已经有数据，只需通过添加新的子字段来修改映射，如下所示：

PUT my-index/_mapping/doc
{
  "properties": {
    "eng": {
      "soc_er_score" : {
        "type" : "text",
        "fields" : {
          "keyword" : {
            "type" : "keyword",
            "ignore_above" : 256
          },
          "numeric" : {
            "type" : "long",
            "ignore_malformed": true
          }
        }
      }
    }
  }
}

然后调用update by queryendpoint以获取新的映射：

POST my-index/_update_by_query

完成后，将为所有现有文档索引eng.soc_er_score.numeric字段。