def create_collection(self, schemas):

        idx_manager = self.idx_manager
        if idx_manager.exists(self.index):
            idx_manager.delete(index=self.index)

        mapper = ESSchemaMapper(idx_manager)
        for schema in schemas:
            schema.map(mapper)

        mapper.create(self.index)
Init the collections the first time.
dataset/ETHPy150Open Net-ng/kansha/kansha/services/search/elasticengine.py/ElasticSearchEngine.create_collection