Reindexedit
The reindex
API extracts the document source from the source index and indexes
the documents into the destination index. You can copy all documents to the
destination index, reindex a subset of the documents or update the source before
to reindex it.
In the following example we have a game-of-thrones
index which contains
different quotes of various characters, we want to create a new index only for
the house Stark and remove the house
field from the document source.
'use strict' const { Client } = require('@elastic/elasticsearch') const client = new Client({ cloud: { id: '<cloud-id>' }, auth: { apiKey: 'base64EncodedKey' } }) async function run () { await client.index({ index: 'game-of-thrones', document: { character: 'Ned Stark', quote: 'Winter is coming.', house: 'stark' } }) await client.index({ index: 'game-of-thrones', document: { character: 'Arya Stark', quote: 'A girl is Arya Stark of Winterfell. And I\'m going home.', house: 'stark' } }) await client.index({ index: 'game-of-thrones', refresh: true, document: { character: 'Tyrion Lannister', quote: 'A Lannister always pays his debts.', house: 'lannister' } }) await client.reindex({ wait_for_completion: true, refresh: true, source: { index: 'game-of-thrones', query: { match: { house: 'stark' } } }, dest: { index: 'stark-index' }, script: { lang: 'painless', source: 'ctx._source.remove("house")' } }) const result = await client.search({ index: 'stark-index', query: { match_all: {} } }) console.log(result.hits.hits) } run().catch(console.log)