我试图在针对ElasticSearch进行测试的套件上提高性能。

测试需要很长时间，因为Elasticsearch在更新后不会立即更新其索引。例如，以下代码在运行时不会引发断言错误。

from elasticsearch import Elasticsearch
elasticsearch = Elasticsearch('es.test')

# Asumming that this is a clean and empty elasticsearch instance
elasticsearch.update(
     index='blog',
     doc_type=,'blog'
     id=1,
     body={
        ....
    }
)

results = elasticsearch.search()
assert not results
# results are not populated

目前，针对该问题的解决方案是将time.sleep调用放到代码中，以给ElasticSearch一些时间来更新其索引。

from time import sleep
from elasticsearch import Elasticsearch
elasticsearch = Elasticsearch('es.test')

# Asumming that this is a clean and empty elasticsearch instance
elasticsearch.update(
     index='blog',
     doc_type=,'blog'
     id=1,
     body={
        ....
    }
)

# Don't want to use sleep functions
sleep(1)

results = elasticsearch.search()
assert len(results) == 1
# results are now populated

显然，这并不是一件好事，因为它很容易出现故障，假设如果ElasticSearch花费多于一秒钟的时间来更新其索引，尽管测试不太可能失败。同样，当您运行100个这样的测试时，它也非常慢。

我试图解决该问题的方法是查询挂起的群集作业，以查看是否还有任何任务需要完成。但是，这不起作用，并且此代码将在没有断言错误的情况下运行。

from elasticsearch import Elasticsearch
elasticsearch = Elasticsearch('es.test')

# Asumming that this is a clean and empty elasticsearch instance
elasticsearch.update(
     index='blog',
     doc_type=,'blog'
     id=1,
     body={
        ....
    }
)

# Query if there are any pending tasks
while elasticsearch.cluster.pending_tasks()['tasks']:
    pass

results = elasticsearch.search()
assert not results
# results are not populated

所以基本上，回到我的原始问题，ElasticSearch更新不是立即的，您如何等待ElasticSearch完成对其索引的更新？