[Elasticsearch - Node.js] Upsert by query

upsert_by_query.js

// - Try to update matching documents using _update_by_query (https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update-by-query.html)
// - If no matching documents, index a new one with desired data
//
// Install Elasticsearch Node.js client: npm install @elastic/elasticsearch

const { Client } = require('@elastic/elasticsearch')
const client = new Client({ node: 'http://localhost:9200' })


client.updateByQuery({
    index: 'my_index',
    refresh: true,
    body: {
        script: {
            lang: 'painless',
            source: 'ctx._source.field_name="new_value";'
        },
        query: {
            term: {
                field_name: "value"
            }
        }
    }
}, (err, result) => {
    if (result.body.total == 0) { // no hits to update
        client.index({
            index: 'my_index',
            body: {
                field_name: 'new_value'
            }
        })
    }
})