使用 Elasticsearch 的连接超时

Question

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'])

这简化了代码返回以下错误：

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

很奇怪，因为服务器已经准备好并设置好了（http://localhost:9200/ 返回了一些json）。

Answer 1

如果您使用Amazon弹性搜索服务，可能会出现连接超时问题。

es = Elasticsearch([{'host': 'xxxxxx.us-east-1.es.amazonaws.com', 'port': 443,  'use_ssl': True}])

上面的python代码覆盖了从9200到443的默认端口并将SSL设置为true将解决问题。

如果未指定端口，则尝试连接到指定主机中的端口9200，超时后失败

Answer 2

尝试在Elasticsearch初始化中设置超时：

es = Elasticsearch([{'host': HOST_ADDRESS, 'port': THE_PORT}], timeout=30)

您甚至可以将retry_on_timeout设置为 True，并为max_retries提供一个可选数字：

es = Elasticsearch([{'host': HOST_ADDRESS, 'port': THE_PORT}], timeout=30, max_retries=10, retry_on_timeout=True)

Answer 3

默认情况下，超时值设置为10秒。如果要更改全局超时值，可以通过在创建对象时设置标志timeout=您的时间来实现。

如果您已经创建了对象，但没有指定超时值，那么您可以通过在查询中使用request_timeout=your-time标志来设置特定请求的超时值。

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