Elasticsearch обновляет все поле _source на основе поискового запроса

Вы можете добиться того, чего хотите, используя обновить с помощью API запроса, примерно так:

POST index/_update_by_query
{
  "query": {
    "match": {
      "id": "5b1676493d21784208c36041"
    }
  },
  "script": {
    "source": "ctx._source = params",
    "params": {
       "dataSource": "ELASTIC",
       "entity": "vertices",
       "label": "vertices"
    }
  }
}

ОБНОВЛЕНИЕ: использование Java API

Map<String, String> params = new HashMap<>();
params.put("dataSource", "ELASTIC");
params.put("entity", "vertices");
params.put("label", "vertices");

UpdateByQueryRequestBuilder updateByQuery = UpdateByQueryAction.INSTANCE.newRequestBuilder(client);
updateByQuery.source("index")
    .filter(QueryBuilders.matchQuery("id", "5b1676493d21784208c36041"))
    .size(1000)
    .script(new Script(ScriptType.INLINE, "painless", "ctx._source.putAll(params)", params));
BulkByScrollResponse response = updateByQuery.get();

Дополнительные сведения об использовании UpdateByQuery Java API и Java-клиент отдыха высокого уровня

"ctx._source.putAll(params)" была хорошей попыткой, но, к сожалению, она перемещает все существующие поля под _source.ctx.

Итак, у меня работает следующее (ES 6.1):

"for (k in params.keySet()){if (!k.equals('ctx')){ctx._source.put(k, params.get(k))}}"

Спасибо @jetnet за идею перебрать все записи на карте. Когда я использовал сценарий, он все еще заменял весь объект, поэтому мне пришлось адаптировать его, как показано ниже, чтобы сохранить поля, не предоставленные во время операции обновления. Для контекста, если я сначала вставлю документ, который имеет три объекта, каждый с 2 ​​полями, если я затем обновлю этот документ с теми же 3 объектами, но с 1 полем каждый, вывод будет таким, что я получаю документ с 3 объектами каждый с 1 полем вместо 3 объектов по 2 поля, как было у меня изначально.

Мне пришлось адаптировать скрипт @jetnet, чтобы получить желаемый результат: не перезаписывать свойства объекта.

POST /transaction_index/_update/33384637-3137-3132-5543-31304c4c3151
{
   "script": {
      "source": "if (ctx._source.Metadata == null || params.Metadata.Version >= ctx._source.Metadata.Version) { for (k in params.keySet()){ if (ctx._source[k] != null) { ctx._source[k].putAll(params.get(k)) } else { ctx._source.put(k, params.get(k)) } } } else { ctx.op = 'none' }",
      "params": {
         "Transaction": {
            "TransactionId": "33384637-3137-3132-5543-31304c4c3151",
            "TransactionKey": "Key1"
         },
         "Message": {
            "MessageId": "505a5953-374a-385a-4a48-52353549445a",
            "Context": "This is a test context"
         },
         "MessageDefinition": {
            "MessageDefinitionId": "a1c05e06-fa6b-40ce-992f-d083ff6c0243",
            "Code": 1010101010
         },
         "Metadata": {
            "Version": 1,
            "CreateTime": "2020-09-04T14:27:51.1986439+01:00",
            "IsLatest": true,
            "IsDummy": false,
            "VersionString": "20200903111111"
         }
    }
 },
 "scripted_upsert": true,
 "upsert": {}
}