actions/opensearch-pyd
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

draft of docs for backoff helper

Browse Source
This commit is contained in:
Honza Král
2017-07-18 18:08:00 -04:00
parent b31b5ddae6
commit a16679b2cf
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
elasticsearch/helpers/__init__.py
+5 -1
View File
@@ -145,6 +145,11 @@ def streaming_bulk(client, actions, chunk_size=500, max_chunk_bytes=100 * 1024 *
bulk that returns summary information about the bulk operation once the bulk that returns summary information about the bulk operation once the
entire input is consumed and sent. entire input is consumed and sent.
If you specify ``max_retries`` it will also retry any documents that were
rejected with a ``429`` status code. To do this it will wait (**by calling
time.sleep which will block**) for ``initial_backoff`` seconds and then,
every subsequent rejection for the same chunk, for double the time every
time up to ``max_backoff`` seconds.
:arg client: instance of :class:`~elasticsearch.Elasticsearch` to use :arg client: instance of :class:`~elasticsearch.Elasticsearch` to use
:arg actions: iterable containing the actions to be executed :arg actions: iterable containing the actions to be executed
@@ -163,7 +168,6 @@ def streaming_bulk(client, actions, chunk_size=500, max_chunk_bytes=100 * 1024 *
retry. Any subsequent retries will be powers of ``inittial_backoff * retry. Any subsequent retries will be powers of ``inittial_backoff *
2**retry_number`` 2**retry_number``
:arg max_backoff: maximum number of seconds a retry will wait :arg max_backoff: maximum number of seconds a retry will wait
""" """
actions = map(expand_action_callback, actions) actions = map(expand_action_callback, actions)