Firebase Cloud Function中的Async / await表示Error Expression的类型为“void”

问题描述 投票:0回答:2

我正在尝试在我的firebase函数中使用async / await,但是我收到了一个错误。我已将该函数标记为异步,但当我尝试在其中使用await时,我得到错误:Expression有类型void。把它作为一个声明放在自己的路上。

我认为这很奇怪,因为我认为每个等待函数调用已经在它自己的行中作为一个语句。所以,我不知道该怎么做。任何帮助,将不胜感激。

为清楚起见,我正在向Cheerio web scrape库发出请求,然后尝试使用.each方法在每个循环期间进行两次异步函数调用。

export const helloWorld = functions.https.onRequest((req, response) => {


const options = {
uri: 'https://www.cbssports.com/nba/scoreboard/',
transform: function (body) {
    return cheerio.load(body);
}
};

request(options)
.then(($) => {


$('.live-update').each((i, element) => {

        const homeTeamAbbr = $(element).find('tbody').children('tr').eq(0).find('a').html().split("alt/").pop().split('.svg')[0];
        const awayTeamAbbr = $(element).find('tbody').children('tr').eq(1).find('a').html().split("alt/").pop().split('.svg')[0];
        const homeTeam = $(element).find('tbody').children('tr').eq(0).find('a.team').text().trim();
        const awayTeam = $(element).find('tbody').children('tr').eq(1).find('a.team').text().trim();
        let homeTeamStatsURL = $(element).find('tbody').children('tr').eq(0).find('td').html();
        let awayTeamStatsURL = $(element).find('tbody').children('tr').eq(1).find('td').html();
        const gameTime = $(element).find('.pregame-date').text().trim();

        homeTeamStatsURL = homeTeamStatsURL.match(/href="([^"]*)/)[1] + "roster";
        awayTeamStatsURL = awayTeamStatsURL.match(/href="([^"]*)/)[1] + "roster";

        const matchupString = awayTeamAbbr + "@" + homeTeamAbbr;
        const URLString = "NBA_" + urlDate + "_" + matchupString;
        // var docRef = database.collection('NBASchedule').doc("UpcommingSchedule");
        // var boxScoreURL = "www.cbssports.com/nba/gametracker/boxscore/" + URLString;

        // var setAda = docRef.set({[URLString]:{
        //   homeTeam: homeTeam,
        //   awayTeam: awayTeam,
        //   date: gameTime,
        //   homeTeamAbbr: homeTeamAbbr,
        //   awayTeamAbbr: awayTeamAbbr,
        //   homeTeamStatsURL: homeTeamStatsURL,
        //   awayTeamStatsURL: awayTeamStatsURL,
        //   boxScoreURL: boxScoreURL
        // }}, { merge: true });

         getTeamPlayers(homeTeamStatsURL, matchupString);
         getTeamPlayers(awayTeamStatsURL, matchupString);

        console.log("retrieved schedule for "+ matchupString + " on " + urlDate)



});

 response.send("retrieved schedule");
})
.catch(function (err) {
   console.log("error " + err);
});

});

我调用的函数只是发出另一个请求然后我正在尝试记录一些数据。

function getTeamPlayers(playerStatsURL, matchupString) {


const options = {
    uri: playerStatsURL,
    transform: function (body) {
        return cheerio.load(body);
    }
};

 console.log(playerStatsURL + " stats url");

request(options)

.then(($) => {

    console.log('inside cheerio')

     $('tbody').children('tr').each(function(i, element){

        const playerName = $(element).children('td').eq(1).children('span').eq(1).find('a').text().trim();

        const injury = $(element).children('td').eq(1).children('span').eq(1).children('.icon-moon-injury').text().trim();
        const news = $(element).children('td').eq(1).children('span').eq(1).children('.icon-moon-news').text().trim();

        const playerUrl = $(element).children('td').eq(1).children('span').eq(1).find('a').attr('href');
        const playerLogsUrl = "https://www.cbssports.com" + playerUrl.replace('playerpage', 'player/gamelogs/2018');

        console.log(playerName + ": Inj: " + injury + " News: " + news);



        // database.collection('NBAPlayers').add({[playerName]:{
        //   '01 playerName': playerName,
        //   '03 playerLogsUrl': playerLogsUrl,
        //   '04 inj': injury,
        //   '05 news': news

        // }})
      //   .then(docRef => {

      //     console.log("ID " + docRef.id);
      //     //getPlayerLogs(playerLogsUrl, playerName, docRef.id);

      //   })
      //   .catch(error => console.error("Error adding document: ", error));
       });

});

}

javascript firebase async-await google-cloud-functions
2个回答
0
投票

节点版本8(可部署为Firebase的云功能)支持async/await。具体来说,使用8.6.1(在撰写本文时)。

至于在循环中等待x2 - 我不认为这是最佳实践。

相反,将所有这些请求推送到一个数组,然后Promise.all以便并行获取所有请求。


0
投票

以防万一有人来。正如Ron之前所说,如果第二次调用不需要第一次调用的值,则不应在传统的for循环中使用async/await,因为这样会增加代码的运行时间。

此外,你不能在async/awaitforEach=>循环中使用map=>,因为它不会停止并等待承诺解决。

最有效的方法是使用Promise.all([])。在这里,我留下了一个很棒的youtube视频,解释了async/await和Promises => https://www.youtube.com/watch?v=vn3tm0quoqE&t=6s

关于DarkHorse评论中的一个问题:

但我想要的是让getTeamPlayers()执行并写入数据库,所以我不知道为什么我需要返回任何东西。

在Firebase函数中,所有函数都需要在最终响应之前返回一些内容。

例如,在这种情况下,他创建了一个http函数。在他用response.send("retrieved schedule");结束函数之前,你需要完成触发的每个函数。由于Firebase功能将在最终的response之后清理,删除并停止任何仍在运行的内容。所以任何未完成的功能都会在完成工作之前被杀死。

返回承诺是Firebase函数知道所有执行完成并可以清理的方式。

跳它有帮助:)

© www.soinside.com 2019 - 2024. All rights reserved.