バルクロードのElastic Searchで要求タイムアウトを設定する

Question

Elasticsearch Bulkアップロードでリクエスト時間を20秒以上に設定したかったのですが、デフォルトの時間は10秒に設定され、私の警告メッセージの日数は10.006秒です。そして、実行を表示した直後にエラーが発生しました

これで、ユーザーからの入力を要求するたびに、またはデフォルトで設定されたすべての要求に対して、要求タイムアウトを設定したかったのです。

エラーメッセージ：

WARNING:elasticsearch:HEAD /opportunityci/predictionsci [status:404 request:0.080s] 
validated the index and mapping...! 
WARNING:elasticsearch:POST http://192.168.204.154:9200/_bulk [status:N/A request:10.003s] 
Traceback (most recent call last): 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/elasticsearch/connection/http_urllib3.py", line 94, in perform_request 
    response = self.pool.urlopen(method, url, body, retries=False, headers=self.headers, **kw) 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/urllib3/connectionpool.py", line 640, in urlopen 
    _stacktrace=sys.exc_info()[2]) 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/urllib3/util/retry.py", line 238, in increment 
    raise six.reraise(type(error), error, _stacktrace) 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/urllib3/connectionpool.py", line 595, in urlopen 
    chunked=chunked) 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/urllib3/connectionpool.py", line 395, in _make_request 
    self._raise_timeout(err=e, url=url, timeout_value=read_timeout) 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/urllib3/connectionpool.py", line 315, in _raise_timeout 
    raise ReadTimeoutError(self, url, "Read timed out. (read timeout=%s)" % timeout_value) 
ReadTimeoutError: HTTPConnectionPool(host='192.168.204.154', port='9200'): Read timed out. (read timeout=10) 
ERROR:DataScience:init exception : Traceback (most recent call last): 
    File "/Users/adaggula/Documents/workspace/LatestDemo/demo/com/ci/dataScience/engine/Driver.py", line 194, in <module> 
    sample.persist(finalResults) 
    File "/Users/adaggula/Documents/workspace/LatestDemo/demo/com/ci/dataScience/ES/sample.py", line 68, in persist 
    res = helpers.bulk(client,data,stats_only=True) 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/elasticsearch/helpers/__init__.py", line 188, in bulk 
    for ok, item in streaming_bulk(client, actions, **kwargs): 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/elasticsearch/helpers/__init__.py", line 160, in streaming_bulk 
    for result in _process_bulk_chunk(client, bulk_actions, raise_on_exception, raise_on_error, **kwargs): 
    File "/Users/adaggula/anaconda/lib/python2.7/site-packages/elasticsearch/helpers/__init__.py", line 89, in _process_bulk_chunk 
    raise e 
ConnectionTimeout: ConnectionTimeout caused by - ReadTimeoutError(HTTPConnectionPool(host='192.168.204.154', port='9200'): Read timed out. (read timeout=10)) 

Answer 1

使用パラメータ'request_timeout'

例えば：

bulk(es, records, chunk_size=500, request_timeout=20)