Elasticsearch-py update API with script

Question

I'm trying to use the Update API via the elasticsearch-py python client on ES 2.1.1 and I'm having trouble.

es.index(index='boston', doc_type='stem_map', id=111, body={'word': 'showing', 'counter': 29})
es.get(index='boston', doc_type='stem_map', id=111)

{'_id': '111',
 '_index': 'boston',
 '_source': {'counter': 29, 'word': 'showing'},
 '_type': 'stem_map',
 '_version': 1,
 'found': True}

upscript = {
    'script': {
        'inline': 'ctx._source.counter += count', 
        'params': {
            'count': 100
        }
    }
}

Then I tried both of the following:

es.update(index='boston', doc_type='stem_map', id=111, body=upscript)
es.update(index='boston', doc_type='stem_map', id=111, script=upscript)

I'm getting the following error:

RequestError: TransportError(400, 'illegal_argument_exception', '[John Walker][127.0.0.1:9300][indices:data/write/update[s]]')

Does anybody know what I'm doing wrong?

UPDATE: This also does not work

es.index(index='boston', doc_type='stem_map', id='111', body={'word': 'showing', 'counter': 29})

{'_id': '111',
 '_index': 'boston',
 '_shards': {'failed': 0, 'successful': 1, 'total': 2},
 '_type': 'stem_map',
 '_version': 1,
 'created': True}

upscript = {
   "script" : "ctx._source.counter += count",
   "params" : {
      'count': 100
   }
}

es.update(index='boston', doc_type='stem_map', id='111', body=upscript)

WARNING:elasticsearch:POST /boston/stem_map/111/_update [status:400 request:0.002s]
...
RequestError: TransportError(400, 'illegal_argument_exception', '[Atum][127.0.0.1:9300][indices:data/write/update[s]]')

ANSWER: My mistake. I didn't realize I had to enable scripting on ES first by changing the config/elasticsearch.yml file. My original code works after enabling scripting.

You could see this post stackoverflow.com/questions/35046765/… — OneCricketeer
– OneCricketeer, Commented Jan 28, 2016 at 5:21

OneCricketeer · Accepted Answer · 2016-01-28 04:32:50Z

2

I think your upscript is the wrong format. Try this

upscript = {
   "script" : "ctx._source.counter += count",
   "params" : {
      'count': 100
   }
}

And use body=upscript.

Using script=upscript doesn't work because that requires a url-encoded string of ctx._source.counter += count with the body being {"params" : { "count" : 100 }}.

answered Jan 28, 2016 at 4:32

OneCricketeer

193k20 gold badges146 silver badges276 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

plam Over a year ago

upscript = {    "script" : "ctx._source.counter += count",    "params" : {       'count': 100    } }  es.update(index='boston', doc_type='stem_map', id=111, body=upscript)

This still gives me an error: RequestError: TransportError(400, 'illegal_argument_exception', '[Atum][127.0.0.1:9300][indices:data/write/update[s]]')

OneCricketeer Over a year ago

Your id parameter should be a string, not an int. Other than that, are you sure the index and doc_type are correct?

plam Over a year ago

Yep. Still doesn't work. See my update. It clearly shows that the document is indexing correctly with the same index and doc_type.

plam · Accepted Answer · 2016-01-28 05:27:53Z

0

My mistake. I did not realize that I had to first enable scripting on elasticsearch. My original code works after enabling scripting.

answered Jan 28, 2016 at 5:27

plam

1,3853 gold badges17 silver badges25 bronze badges

2 Comments

OneCricketeer Over a year ago

Oops. Just saw this. Was your original code correct, or was I also right with the upscript?

plam Over a year ago

Both your version of the upscript and my version worked with the body parameter, so we were both right!

Collectives™ on Stack Overflow

Elasticsearch-py update API with script

2 Answers 2

3 Comments

2 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

3 Comments

2 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related