Connection Timeout with Elasticsearch

python python-2.7 elasticsearch
Johann Gomes picture Johann Gomes · Feb 2, 2015 · Viewed 89.4k times · Source 
from datetime import datetime
from elasticsearch import Elasticsearch
es = Elasticsearch()

doc = {
    'author': 'kimchy',
    'text': 'Elasticsearch: cool. bonsai cool.',
    'timestamp': datetime(2010, 10, 10, 10, 10, 10)
}
res = es.index(index="test-index", doc_type='tweet', id=1, body=doc)
print(res['created'])

This simples code is returning the following error:

elasticsearch.exceptions.ConnectionTimeout: ConnectionTimeout caused by - ReadTimeoutError(HTTPConnectionPool(host='localhost', port=9200): Read timed out. (read timeout=10))

Very strange, because the server is ready and set (http://localhost:9200/ is returning some json).

Answer

Rahul picture Rahul · Jun 27, 2015

By default, the timeout value is set to 10 secs. If one wants to change the global timeout value, this can be achieved by setting the flag timeout=your-time while creating the object.

If you have already created the object without specifying the timeout value, then you can set the timeout value for particular request by using request_timeout=your-time flag in the query.

es.search(index="my_index",
          doc_type="document",
          body=get_req_body(),
          request_timeout=30)

Related questions

Elasticsearch : How to delete an Index using python

Forgive me if this is quite basic but I have Python 2.7 and Elasticsearch 2.1.1 and I am just trying to delete an index using es.delete(index='researchtest', doc_type='test') but this gives me return func(*args, params=params, **kwargs) …

Read More
User authentication in Elasticsearch query using python

I'm using elastisearch using Python. My code looks somewhat like this:- from elasticsearch import Elasticsearch if __name__ == '__main__': index="IndexPosition" es=Elasticsearch(['https://localhost:8080']) res = es.search(index='{0}'.format(index), doc_type="log",size=1000, …

Read More
Python elasticsearch.helpers.scan example

Can someone provide scan API example of python elasticsearch helpers client? res = elasticsearch.helpers.scan(....) How can i get all results from elasticsearch with res object?

Read More