大きなインデックスを再インデックスしていますが、新しいインデックスにエイリアスを追加するために古いインデックスを削除する必要があります。
helpers.reindex(client=es, source_index=index_old, target_index=index_new, )
# those 2 need to run when reindex finishes
es.indices.delete(index=index_old)
es.indices.put_alias(index=index_new, name=index_old)
問題は、最後の 2 つのコマンドが reindex が完了するまで待機する必要があることです。そうしないと、元のインデックスが削除され、機能しなくなります。
Elasticsearch には refresh=wait_for がありますが、python helpers.reindex にはありません。
再インデックスを同期させるには、どのようなアプローチが適していますか?