tasks.py 文件源码

def es_index_instance(sender, instance, created, **kwargs):
    """Signal receiver function for Creating/Indexing a model into
    elasticsearch

    """
    indexer = ModelIndex.indexer_for_instance(instance)
    if indexer is not None:
        indexable_func = getattr(indexer, 'indexable', None)
        if callable(indexable_func):
            if indexable_func():
                indexer.save()
            else:
                indexer.delete()
        else:
            indexer.save()