我已经实现了批量索引。我想提高效率。

# current implementation in Python

def products_to_index():
    for product in all_products():
        yield {
            "_op_type": "index",
            "_index": INDEX_NAME,
            "_id": product.id,
            "_source": {"name": product.name, "content": product.content},
        }

def main(args):
    # Connect to localhost:9200 by default.
    es = Elasticsearch()
    body = ANALYZER  

    es.indices.create(index=INDEX_NAME, body=body)

    bulk(es, products_to_index())

这个实现似乎只是获取所有的数据，并对它们逐批进行索引。我想实施一个额外的步骤来检查这个条目是否已经被索引。
我还考虑过从本地保存的索引路径加载。不知道如何进行。
我看了api文档，但找不到。