API обновления по запросу

const response = await client.ingest.putPipeline({
  id: "set-foo",
  description: "sets foo",
  processors: [
    {
      set: {
        field: "foo",
        value: "bar",
      },
    },
  ],
});
console.log(response);

const response1 = await client.updateByQuery({
  index: "my-index-000001",
  pipeline: "set-foo",
});
console.log(response1);

const response = await client.tasks.list({
  detailed: "true",
  actions: "*byquery",
});
console.log(response);

const response = await client.tasks.get({
  task_id: "r1A2WoRbTwKZ516z6NEs5A:36619",
});
console.log(response);

const response = await client.tasks.cancel({
  task_id: "r1A2WoRbTwKZ516z6NEs5A:36619",
});
console.log(response);

const response = await client.updateByQueryRethrottle({
  task_id: "r1A2WoRbTwKZ516z6NEs5A:36619",
  requests_per_second: "-1",
});
console.log(response);

const response = await client.updateByQuery({
  index: "my-index-000001",
  slice: {
    id: 0,
    max: 2,
  },
  script: {
    source: "ctx._source['extra'] = 'test'",
  },
});
console.log(response);

const response1 = await client.updateByQuery({
  index: "my-index-000001",
  slice: {
    id: 1,
    max: 2,
  },
  script: {
    source: "ctx._source['extra'] = 'test'",
  },
});
console.log(response1);

const response = await client.indices.refresh();
console.log(response);

const response1 = await client.search({
  index: "my-index-000001",
  size: 0,
  q: "extra:test",
  filter_path: "hits.total",
});
console.log(response1);

const response = await client.updateByQuery({
  index: "my-index-000001",
  refresh: "true",
  slices: 5,
  script: {
    source: "ctx._source['extra'] = 'test'",
  },
});
console.log(response);

const response = await client.search({
  index: "my-index-000001",
  size: 0,
  q: "extra:test",
  filter_path: "hits.total",
});
console.log(response);

const response = await client.indices.create({
  index: "test",
  mappings: {
    dynamic: false,
    properties: {
      text: {
        type: "text",
      },
    },
  },
});
console.log(response);

const response1 = await client.index({
  index: "test",
  refresh: "true",
  document: {
    text: "words words",
    flag: "bar",
  },
});
console.log(response1);

const response2 = await client.index({
  index: "test",
  refresh: "true",
  document: {
    text: "words words",
    flag: "foo",
  },
});
console.log(response2);

const response3 = await client.indices.putMapping({
  index: "test",
  properties: {
    text: {
      type: "text",
    },
    flag: {
      type: "text",
      analyzer: "keyword",
    },
  },
});
console.log(response3);

const response = await client.search({
  index: "test",
  filter_path: "hits.total",
  query: {
    match: {
      flag: "foo",
    },
  },
});
console.log(response);

const response = await client.updateByQuery({
  index: "test",
  refresh: "true",
  conflicts: "proceed",
});
console.log(response);

const response1 = await client.search({
  index: "test",
  filter_path: "hits.total",
  query: {
    match: {
      flag: "foo",
    },
  },
});
console.log(response1);