node.js - 在Elasticsearch上按顺序重新索引和删除

Question

我将需要重新索引，删除旧索引并从旧删除的索引中重命名为名称，它将在NodeJS中以随机顺序执行，尝试删除和重命名值不存在。
我确实尝试过以没有成功的 promise 运行，并使用.then(function(resp)，并且发生了同样的问题。

es.reindex({
    refresh: true,
    body: {
        "source": {
            "index": current_index
        },
        "dest": {
            "index": current_index + ".tmp"
        }
    }
});
es.indices.delete({
    index: current_index,
    ignore: [404]
}, function(err, resp, respcode) {
    if (err) {
        console.log("Error deleting index " + current_index);
        console.log("   Error: " + err);
        console.log("   Resp code: " + respcode);
    }
});
es.reindex({
    refresh: true,
    body: {
        "source": {
            "index": current_index + ".tmp"
        },
        "dest": {
            "index": current_index
        }
    }
});
es.indices.delete({
    index: current_index + ".tmp",
    ignore: [404]
}, function(err, resp, respcode) {
    if (err) {
        console.log("Error deleting index " + current_index);
        console.log("   Error: " + err);
        console.log("   Resp code: " + respcode);
    }
});

Answer 1

这是正确的做法:

const {reindex1Body} = await es.reindex({
    refresh: true,
    body: {
        "source": {
            "index": current_index
        },
        "dest": {
            "index": current_index + ".tmp"
        }
    }
});

try {
    await es.indices.delete({
        index: current_index
    }, {
        ignore: [404]
    });
} catch (err) {
    console.log("Error deleting index " + current_index);
    console.log("   Error: " + err);
    console.log("   Resp code: " + err.statusCode);
}

const {reindex2Body} = await es.reindex({
    refresh: true,
    body: {
        "source": {
            "index": current_index + ".tmp"
        },
        "dest": {
            "index": current_index
        }
    }
});

try {
    await es.indices.delete({
        index: current_index + ".tmp"
    }, {
        ignore: [404]
    });
} catch (err) {
    console.log("Error deleting index " + current_index);
    console.log("   Error: " + err);
    console.log("   Resp code: " + err.statusCode);
}