5

根据官方文档更新 API - Upserts可以用来scripted_upsert在脚本中处理更新（对于现有文档）或插入（对于新文档）表单。问题是他们从不展示脚本应该如何做到这一点。Java - 更新 API没有关于 ScriptUpsert 使用的任何信息。

这是我正在使用的代码：

//My function to build and use the upsert
public void scriptedUpsert(String key, String parent, String scriptSource, Map<String, ? extends Object> parameters) {
    Script script = new Script(scriptSource, ScriptType.INLINE, null, parameters);
    UpdateRequest request = new UpdateRequest(index, type, key);
    request.scriptedUpsert(true);
    request.script(script);
    if (parent != null) {
        request.parent(parent);
    }
    this.bulkProcessor.add(request);
}

//A test call to validate the function
String scriptSource = "if (!ctx._source.hasProperty(\"numbers\")) {ctx._source.numbers=[]}";
Map<String, List<Integer>> parameters = new HashMap<>();
List<Integer> numbers = new LinkedList<>();
numbers.add(100);
parameters.put("numbers", numbers);

bulk.scriptedUpsert("testUser", null, scriptSource, parameters);

当“testUser”文档不存在时，我收到以下异常：
DocumentMissingException[[user][testUser]: document missing

如何使 scriptUpsert 从 Java 代码工作？

4

2 回答 2

4

这是scripted_upsert命令的外观（及其脚本）：

POST /sessions/session/1/_update
{
  "scripted_upsert": true,
  "script": {
    "inline": "if (ctx.op == \"create\") ctx._source.numbers = newNumbers; else ctx._source.numbers += updatedNumbers",
    "params": {
      "newNumbers": [1,2,3],
      "updatedNumbers": [55]
    }
  },
  "upsert": {}
}

如果您调用上述命令并且索引不存在，它将与newNumbers新文档中的值一起创建它。如果再次调用完全相同的命令，numbers值将变为1,2,3,55.

在您的情况下，您缺少"upsert": {}部分。

于 2016-08-02T11:57:38.850 回答
0

正如安德烈建议的那样，我错过了 upsert 部分，将函数更改为：

public void scriptedUpsert(String key, String parent, String scriptSource, Map<String, ? extends Object> parameters) {
    Script script = new Script(scriptSource, ScriptType.INLINE, null, parameters);
    UpdateRequest request = new UpdateRequest(index, type, key);
    request.scriptedUpsert(true);
    request.script(script);
    request.upsert("{}"); // <--- The change
    if (parent != null) {
        request.parent(parent);
    }
    this.bulkProcessor.add(request);
}

修理它。

于 2016-08-02T12:04:46.753 回答