#NEWLINE# def streaming_bulk( client , actions , chunk_size = 500 , max_chunk_bytes = ( ( 100 * 1024 ) * 1024 ) , raise_on_error = True , expand_action_callback = expand_action , raise_on_exception = True , **kwargs ) : #NEWLINE# #INDENT# "\n    Streaming bulk consumes actions from the iterable passed in and yields\n    results per action. For non-streaming usecases use\n    :func:`~elasticsearch.helpers.bulk` which is a wrapper around streaming\n    bulk that returns summary information about the bulk operation once the\n    entire input is consumed and sent.\n\n\n    :arg client: instance of :class:`~elasticsearch.Elasticsearch` to use\n    :arg actions: iterable containing the actions to be executed\n    :arg chunk_size: number of docs in one chunk sent to es (default: 500)\n    :arg max_chunk_bytes: the maximum size of the request in bytes (default: 100MB)\n    :arg raise_on_error: raise ``BulkIndexError`` containing errors (as `.errors`)\n        from the execution of the last chunk when some occur. By default we raise.\n    :arg raise_on_exception: if ``False`` then don't propagate exceptions from\n        call to ``bulk`` and just report the items that failed as failed.\n    :arg expand_action_callback: callback executed on each action passed in,\n        should return a tuple containing the action line and the data line\n        (`None` if data line should be omitted).\n    " #NEWLINE# actions = map ( expand_action_callback , actions ) #NEWLINE# for bulk_actions in _chunk_actions ( actions , chunk_size , max_chunk_bytes , client . transport . serializer ) : #NEWLINE# #INDENT# for result in _process_bulk_chunk ( client , bulk_actions , raise_on_exception , raise_on_error , ** kwargs ) : #NEWLINE# #INDENT# ( yield result )