滚动弹性搜索，致电API并存储在弹性搜索异步中

Question

我有一个弹性搜索索引（30GB，1M条目），我必须使用调用API（1S执行）更新每个文档，并对结果进行一些计算。

我尝试了很多事情，例如使用AioHTTP发送请求，与Asyncio创建一个队列，

唯一工作的是：

def search_and_store():
    for i in range(1, count, CPU):
        hits = es.search(index=['index'], size=CPU, from_=i)['hits']['hits']
        data = [{"title": hit['_source']['name'], "body": hit['_source']['cleanText'],"id": hit["_id"]} for hit in
                hits]
        print(i)
        with Pool(CPU) as p:
            results = p.map(getresult_store, data)
            p.close()
            p.join()

def getresult_store(item):
    body = ScoreManager.get_article_score(item['title'], item['body'])
    elasticsearchManager.update_record(es, "searchdata", body, item['id'])

但是我确定有最好的方法可以做到这一点