file1.py

def reindex_orgs(org_ids):
    from seed.services import  es_search_query
    from elasticsearch import Elasticsearch
    s = es_search_query()
    s = s.filter('terms', building_snapshot__super_organization=org_ids)
    from seed.services import elasticsearch_client
    es = elasticsearch_client()
    es.delete_by_query(index=settings.ES_INDEX, doc_type='canonical_building', body=s.to_dict())
    from seed.utils.seed_elasticsearch import canon_serializer
    import itertools
    from seed.utils.generic import queryset_iterator_v2
    from elasticsearch.helpers import bulk
    es = Elasticsearch([{'host': settings.ES_HOST}], timeout=120, index='buildingenergy')
    bulk(es, itertools.imap(canon_serializer,queryset_iterator_v2(CanonicalBuilding.objects.filter(canonical_snapshot__super_organization__in=org_ids))))