rac_es/documents.py
def bulk_action(self, connection, actions, max_objects=None):
        """Performs a bulk action on a list of objects.

        This method is strongly preferred over the atomic `save` method, because
        it provides better performance.

        :returns: Elasticsearch identifiers of all indexed objects
        :rtype: list
        """
        indexed = []
        indexed_count = 0
        for ok, result in streaming_bulk(connection, actions, refresh=True):
            action, result = result.popitem()
            if not ok:
                raise Exception(
                    "Failed to {} document {}: {}".format(action, result["_id"], result))
            else:
                indexed.append(result["_id"])
                indexed_count += 1
            if max_objects and indexed_count == max_objects:
                break
        return indexed
Performs a bulk action on a list of objects.

        This method is strongly preferred over the atomic `save` method, because
        it provides better performance.

        :returns: Elasticsearch identifiers of all indexed objects
        :rtype: list
        
Performs a bulk action on a list of objects.
This method is strongly preferred over the atomic `save` method, because
it provides better performance.
Performs a bulk action on a list of objects . This method is strongly preferred over the atomic ` save ` method because it provides better performance .
def bulk_action(self, connection, actions, max_objects=None):
        indexed = []
        indexed_count = 0
        for ok, result in streaming_bulk(connection, actions, refresh=True):
            action, result = result.popitem()
            if not ok:
                raise Exception(
                    "Failed to {} document {}: {}".format(action, result["_id"], result))
            else:
                indexed.append(result["_id"])
                indexed_count += 1
            if max_objects and indexed_count == max_objects:
                break
        return indexed
def bulk_action ( self , connection , actions , max_objects = None ) : indexed = [ ] indexed_count = 0 for ok , result in streaming_bulk ( connection , actions , refresh = True ) : action , result = result . popitem ( ) if not ok : raise Exception ( "Failed to {} document {}: {}" . format ( action , result [ "_id" ] , result ) ) else : indexed . append ( result [ "_id" ] ) indexed_count += 1 if max_objects and indexed_count == max_objects : break return indexed
Performs a bulk action on a list of objects.
Performs a bulk action on a list of objects .
"""Performs a bulk action on a list of objects.

        This method is strongly preferred over the atomic `save` method, because
        it provides better performance.

        :returns: Elasticsearch identifiers of all indexed objects
        :rtype: list
        """
Elasticsearch identifiers of all indexed objects
Elasticsearch identifiers of all indexed objects
list
self
connection
actions
max_objects