utils.py 文件源码

def wait_es(cls):
        es = AsyncElasticsearch(
            ['{}:{}'.format(cls.es_host, cls.es_port)], loop=cls.loop)
        for i in range(40):
            try:
                await es.ping()
            except elasticsearch.ElasticsearchException:
                await asyncio.sleep(0.5, loop=cls.loop)
            else:
                es.close()
                break

        else:
            raise RuntimeError("es connection error")