比较嵌套字段的总和

Question

我正在尝试创建比较和嵌套属性与非嵌套属性的请求

映射：

{
    "mappings": {
        "publishers": {
            "properties": {
                "Accounts": {
                    "type": "nested",
                    "properties": {
                        "FollowersCount": {
                            "type": "long"
                        }
                    }
                },
                "TotalSubscribers": {
                    "type": "long"
                }
            }
        }
    }
}

我要查找sum of Accounts.FollowersCount与TotalSubscribers不相等的文档。

怎么做？

PS：我正在尝试创建这样的内容：

{
    "_source": [
        "TotalSubscribers",
        "Accounts.FollowersCount"
    ],
    "query": {
        "bool": {
            "filter": {
                "script": {
                    "script": {
                        "source": "int total = 0; for (int i = 0; i < doc['Accounts'].length; ++i) {total += doc['Accounts'][i].FollowersCount;} return total == doc['TotalSubscribers'];",
                        "lang": "painless"
                    }
                }
            }
        }
    }
}

但不管用。当我将脚本移动到嵌套块时也会出现同样的问题。那么我就无法访问TotalSubscribers

{
    "query": {
        "term": {
            "PublisherId": 349438
        }
    },
    "script": {
        "source": "ctx._source.TotalSubscribers = ctx._source.Accounts.stream().map(a -> a.FollowersCount).collect(Collectors.summingInt(Integer::intValue));"
    }
}

{
    "error": {
        "root_cause": [
            {
                "type": "script_exception",
                "reason": "runtime error",
                "script_stack": [
                    "java.util.stream.Collectors.lambda$summingInt$11(Collectors.java:467)",
                    "java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)",
                    "java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)",
                    "java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382)",
                    "java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)",
                    "java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)",
                    "java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)",
                    "java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)",
                    "java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)",
                    "a -> a.FollowersCount).collect(Collectors.summingInt(Integer::intValue));",
                    "                                                     ^---- HERE"
                ],
                "script": "ctx._source.TotalSubscribers = ctx._source.Accounts.stream().map(a -> a.FollowersCount).collect(Collectors.summingInt(Integer::intValue));",
                "lang": "painless"
            }
        ],
        "type": "script_exception",
        "reason": "runtime error",
        "script_stack": [
            "java.util.stream.Collectors.lambda$summingInt$11(Collectors.java:467)",
            "java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)",
            "java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)",
            "java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382)",
            "java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)",
            "java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)",
            "java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)",
            "java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)",
            "java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)",
            "a -> a.FollowersCount).collect(Collectors.summingInt(Integer::intValue));",
            "                                                     ^---- HERE"
        ],
        "script": "ctx._source.TotalSubscribers = ctx._source.Accounts.stream().map(a -> a.FollowersCount).collect(Collectors.summingInt(Integer::intValue));",
        "lang": "painless",
        "caused_by": {
            "type": "null_pointer_exception",
            "reason": null
        }
    },
    "status": 500
}

请求2：

{
    "query": {
        "bool": {
            "must": [
                {
                    "term": {
                        "PublisherId": 349438
                    }
                }
            ]
        }
    },
    "script": {
        "source": "int total = 0; for(int i=0;i<=ctx._source.Accounts.size()-1;i++){total += ctx._source.Accounts[i].FollowersCount} ctx._source['TotalSubscribers'] = total"
    }
}

在“total+=ctx._source.accounts[i].followerscount”附近也有错误

请求3：

{
    "query": {
        "bool": {
            "must": [
                {
                    "term": {
                        "PublisherId": 349438
                    }
                }
            ]
        }
    },
    "script": {
        "source": "int total = 0; for(int i=0;i<=ctx._source.Accounts.size()-1;i++){total += i} ctx._source['TotalSubscribers'] = total"
    }
}

工作正常，在更新totalSubscribers==count帐户项之后。但需要的是账户财产，不是我...

Answer 1

这可以通过脚本查询来解决，但是由于无法访问脚本查询中的嵌套文档，因此必须以不同的方式进行。在这些情况下，在顶层添加一个新字段总是容易得多，该字段包含followerscount的总和，您可以将其命名为totalfollowerscount。

首先，您需要使用_update_by_queryendpoint创建该字段，如下所示：

POST your-index/_update_by_query
{
  "script": {
    "source": """
    ctx._source.TotalFollowersCount = ctx._source.Accounts
      .stream()
      .map(a -> a.FollowersCount ?: 0)
      .collect(Collectors.summingInt(Integer::intValue));
    """
  }
}

然后可以使用脚本查询来查找有问题的文档：

GET your-index/_search
{
  "query": {
    "script": {
      "script": "doc.TotalFollowersCount.value != doc.TotalSubscribers.value"
    }
  }
}