如何在“new Promise”块中使用 async/await 从 api 获取数据？

Question

我无法在引发await is only valid in async function 错误的“新承诺”块内使用异步/等待。我不知道它是否可能，但我需要使用它或一种方法来实现我想要的。这是我正在尝试做的事情：

用户键入一个查询，它通过一个名为doesExist 的recursive function。我必须使用递归函数，因为 API 并不总是为查询提供数据。递归函数会尝试 3 次，也就是说，它会发送 3 次 api 请求来获取数据，然后返回错误消息“无法获取数据”。在函数中，我返回一个新的承诺，因为我必须从那里发出 api 请求。

为了获取数据，我之前使用了 request，但现在我想将 axios 与 async/await 一起使用。那么如何在 new Promise 块内使用 axios 和 async/await 呢？

这是request的代码：

router.get('/example', async (req, res) => {

        try{
            const query = 'Superman';
            const data  = await doesExist(query);
    
            if(!data) {
                console.log('No data');
            }
    
            res.render('../views/example', { data, query });
        }catch(err) {
            console.log(err);
        }
        
});
    
    
const doesExist = (query, retries = 0) => {

        const url           = `http://api.example.com/json?fields=${query}`;
        const maxRetries    = 3;
    
        return new Promise(( resolve, reject ) => {
            
            const retry = () => {
                if (retries < maxRetries) {
                    resolve(doesExist(query, retries + 1));
                } else {
                    reject(`Could not get the data after ${retries} retries.`);
                }
            };
    
            request(url, function (error, response, body) {
                if (!error && response.statusCode === 200) {
                    const data = JSON.parse(body);
                    resolve(data);
                } else {
                    retry();
                }
            });
       });
}; 

这就是我尝试使用async/await 引发的错误：

const doesExist = async (query, retries = 0) => {

        const url           = `http://api.example.com/json?fields=${query}`;
        const maxRetries    = 3;
    
        return new Promise(( resolve, reject ) => {
            
            const retry = () => {
                if (retries < maxRetries) {
                    resolve(doesExist(query, retries + 1));
                } else {
                    reject(`Could not get the data after ${retries} retries.`);
                }
            };

            const data = await axios.get(url);

            if(data.statusCode === 200) {
                resolve(data);
            }else{
                retry();
            }
     
       });
}; 

如果不能在 promise 块中使用 async/await，那么请告诉我如何实现它。谢谢

Answer 1

Never pass an async function as the executor to new Promise!如果你想使用async/await 和已经返回承诺的axios，你不需要——也不应该使用——Promise 构造函数到promisify a callback API。随便写

async function doesExist(query, retries = 0) {
    const url           = `http://api.example.com/json?fields=${query}`;
    const maxRetries    = 3;

    const data = await axios.get(url);

    if (data.statusCode === 200) {
       return data;
    } else if (retries < maxRetries) {
       return doesExist(query, retries + 1);
    } else {
       throw new Error(`Could not get the data after ${retries} retries.`);
    }
}

Answer 2

promise 调用的函数必须是这样的“异步”函数。

new Promise (async (Resolve) => {
    await new Promise (async (_Resolve) => {
         console.log ("A");
         _Resolve ();
    });

    console.log ("B");
    Resolve ();
});