NodeJS - Promise 在 redis 池等待中返回未定义的对象

Question

我有一个从 redis-connection-pool 创建的 Redis 池对象。它寻找一个键来获取所有图像标识符的数组。然后，对于每个元素，都会查找另一个 Redis 键，以便将值附加到一个 JSON 对象中。该对象作为对GET 请求的响应返回。

出于某种奇怪的原因（也许是 Redis 错误？），当 Promise 使用正确的数据解析时，使用此 Promise 的函数总是看到一个 undefined 对象。

最初的尝试

async function allImageData() {
    var configPool = redisPools.configPool;
    var resp = {};
    var images = [];
    var imageDetails = {};
    //
    await configPool.get('allImages', async (err, reply) => {
        if (err) {
            resp = {
                'data': {}
            }
            reject(resp)
        } else {
            if (reply === null) {
                resp = {
                    'data': {}
                }
                reject(resp)
            } else {
                imageDetails = JSON.parse(reply)
                images = imageDetails['allImages']
                return new Promise(function (resolve, reject) {
                    imageDetailsCache(images).then(function (result) {
                        resp = {
                            'data': result
                        }
                        resolve(resp) //Correct data; but, received as undefined
                    }).catch(function (result) {
                        resp = {
                            'data': {}
                        }
                        reject(resp)
                    })
                })
            }
        }
    })
}

下一次尝试

Promise 在 Redis get 结束后返回。

async function allMachineData() {
    var configPool = redisPools.configPool;
    var resp = {};
    var images = [];
    var imageDetails = {};
    //
    await configPool.get('allImages', async (err, reply) => {
        if (err) {
            resp = {
                'data': {}
            }
            reject(resp)
        } else {
            if (reply === null) {
                resp = {
                    'data': {}
                }
                reject(resp)
            } else {
                imageDetails = JSON.parse(reply)
                images = imageDetails['allImages']
            }
        }
    })
    return new Promise(function (resolve, reject) {
        // images array is empty; so, received as empty object
        imageDetailsCache(images).then(function (result) {
            resp = {
                'data': result
            }
            resolve(resp)
        }).catch(function (result) {
            resp = {
                'data': {}
            }
            reject(resp)
        })
    })
}

Answer 1

在你的尝试中你使用

await configPool.get('allImages', async (err, reply) => {

首先，.get 不返回承诺，所以awaiting 这没有意义
其次，你没有在回调中使用 await，所以不需要让它 async

看来你的代码可以简化

首先，由于您要返回一个 Promise，请将 configPool.get 包装在一个 Promise 中，这将在回调中解决/拒绝

之后，这只是一个承诺链接的问题，因为您的代码暗示imageDetailsCache 返回一个承诺，这很简单：

function allImageData() {
    return new Promise((resolve, reject) => {
        redisPools.configPool.get('allImages', (err, reply) => err ? reject(err) : resolve(reply));
    })
    .then(reply => {
        if (reply === null) return Promise.reject(null);
        const imageDetails = JSON.parse(reply);
        return imageDetailsCache(imageDetails.allImages);
    })
    .then(data => ({data}))
    .catch(() => Promise.reject({data:{}}));
}