'Creates a new object with the given kwargs, saving it to the database
and returning the created object.'

def create(self, **kwargs):

    obj = self.model(**kwargs)
    meta = obj.get_meta()
    meta.connection = get_es_connection(self.es_url, self.es_kwargs)
    meta.index = self.index
    meta.type = self.type
    obj.save(force=True)
    return obj
