Update by query (updateByQuery) Elasticsearch-PHP

Question

I am Using Elasticsearch 2.3 along with the official php driver. The updateByQuery is giving me troubles to use in php. A little help on how to use it will be appreciated.

        $client = \Elasticsearch\ClientBuilder::create()->setHosts(['127.0.0.1:9200'])->build();
        # Request
        $updateRequest = [
            'index'     => 'gorocket',
            'type'      => 'logs',
            'body' => [
                'query' => [ 
                    'filtered' => [
                        'filter' => [
                            'bool' =>   [
                                            'must' =>
                                            [
                                                [
                                                    'match' => [ 'enabled' => 1 ],
                                                ],
                                            ]
                                        ]
                                    ]
                                ]
                            ]
                  ]
            ]
        ];
        # Update 
        $results = $client->updateByQuery($updateRequest);

Basically i want to update a couple of document fields(name,price) that matches a certain query

Thank you.

See above, i've included a sample code( I don't see why it was necessary because all i asked was a sample code or a clear documentation and i could take it from there ). Who ever down-voted this please provide a reason. — Julius Moshiro
– Julius Moshiro, Commented Aug 26, 2016 at 7:57

Julius Moshiro · Accepted Answer · 2016-08-26 09:28:35Z

So, with the help of how the CURL api works i managed to come up with a way.

First you need to edit your elasticsearch.yml to allow Scripting. Append the following lines at the end.

script.engine.groovy.inline.search: on
script.engine.groovy.inline.aggs: on
script.engine.groovy.inline.update: on

There after you can start doing batch updates using queries as the example bellow.

    $client = \Elasticsearch\ClientBuilder::create()->setHosts(['127.0.0.1:9200'])->build();
    # Request
    $updateRequest = [
        'index'     => 'testindex',
        'type'      => 'logs',
        'conflicts' => 'proceed',
        'body' => [
            'query' => [ 
                'filtered' => [
                    'filter' => [
                        'bool' =>   [
                                        'must' =>
                                        [
                                            [
                                                'match' => [ 'enabled' => 1 ],
                                            ],
                                        ]
                                    ]
                                ]
                            ]
                        ],
            'script' => [
                    'inline' => 'ctx._source.enabled = value',
                    'params' => [
                        'value' => 0
                    ]
            ]
            ]
        ]
    ];
    # Update 
    $results = $client->updateByQuery($updateRequest);

That's it. It is not easily and well documented as of now so.

WiRight · Accepted Answer · 2018-11-16 15:18:31Z

1

I want to add a small addition to the previous answer

You may not add the following params in elasticsearch.yml

script.engine.groovy.inline.search: on
script.engine.groovy.inline.aggs: on
script.engine.groovy.inline.update: on

And your query will be:

$client = \Elasticsearch\ClientBuilder::create()->setHosts(['127.0.0.1:9200'])->build();
# Request
$updateRequest = [
    'index'     => 'testindex',
    'type'      => 'logs',
    'conflicts' => 'proceed',
    'body' => [
        'query' => [ 
            'filtered' => [
                'filter' => [
                    'bool' =>   [
                        'must' => [
                            [
                                'match' => [ 'enabled' => 1 ],
                            ],
                        ]
                    ]
                ]
            ]
        ],
        'script' => [
            'lang' => 'painless',
            'source' => 'ctx._source.enabled = params.value',
            'params' => [
                'value' => 0
            ]
        ]
    ]
];

# Update 
$results = $client->updateByQuery($updateRequest);

edited Nov 16, 2018 at 15:18

answered Nov 16, 2018 at 13:45

WiRight

3618 silver badges14 bronze badges

2 Comments

Suraj Rao Over a year ago

you possibly have an extra ] or two

WiRight Over a year ago

sorry, CopyPaste from previous answer

Collectives™ on Stack Overflow

Update by query (updateByQuery) Elasticsearch-PHP

2 Answers 2

Comments

2 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

2 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related