在承诺中运行同步函数

我是 JS 和异步操作的新手。在使用express的nodeJS路由器中，我使用mongoose从mongo聚合了一些数据。该数据是每隔 15 分钟从不同站点收集的天气数据。我使用猫鼬聚合管道处理数据，以获取每小时数据并按每个站点进行分组。但数据需要进一步处理才能获取相对湿度超过 90% 的时段，并为每个时段分配分数，因此我编写了一些针对每个站点（每个 geojson 对象）的同步函数。

猫鼬看起来像这样：

module.exports.filteredData = function (collection, dateInput) {
return collection.aggregate([

    {
        $addFields :{
            DateObj: {
                $dateFromString: {
                    dateString: "$DateTime",
                    format: '%Y-%m-%d'
                }
            },
        }
    },

    {
        $addFields :{
            NewDateTimes: {
                $dateFromParts:{
                    'year': {$year: '$DateObj'},
                    'month':{$month: '$DateObj'},
                    'day':{$dayOfMonth: '$DateObj'},
                    'hour': {$toInt: "$Time"}
                }
            }
        }
    }

...

同步函数：

const calcDSV = function(featuresJSON){

    // featuresJSON  
    const SVscore = [];
    const tuEval = featuresJSON.features.properties.TU90; // array
    const obArr = featuresJSON.features.properties.OB; // array
    const periodObj =  getPeriods(tuEval);// get period position
    const paramObj =  getParams(periodObj, obArr); // get parameters
    const periodDate =   getPeriodDate(featuresJSON, periodObj);
    const removeTime =  periodDate.beginDate.map(x=>x.split('T')[0]);


    let hourly = paramObj.hourCounts;
    let avgTemps = paramObj.avgTemps;


    for(let i = 0;i<hourly.length; i++){

        let score =  assignScore(avgTemps[i], hourly[i]);
        SVscore.push(score);

    }

    // output sv score for date


    const aggreScore =  accumScore(removeTime, SVscore);


    aggreScore.DSVdate = aggreScore.Date.map(x=>new Date(x));


    featuresJSON.features.properties.periodSV = SVscore;
    featuresJSON.features.properties.Periods = periodDate;
    featuresJSON.features.properties.DSVscore = aggreScore;

    return  featuresJSON;

}

现在我陷入了如何在猫鼬聚合管道根据发布请求返回的每个站点上应用这些函数的问题：

router.post('/form1', (req, res, next)=>{

const emdate = new Date(req.body.emdate);
const address = req.body.address;
const stationDataCursor = stationData.filteredData(instantData, emdate);

stationDataCursor.toArray((err, result)=>{
    if(err){
        res.status(400).send("An error occurred in Data aggregation")
    };


    res.json(result.map(x=>calcDSV.calcDSV(x)));


})


});

我在回调中尝试过：

stationDataCursor.toArray((err, result)=>{
    if(err){
        res.status(400).send("An error occurred in Data aggregation")
    };


    res.json(result.map(async (x)=>await calcDSV.calcDSV(x))));


})

并使用 then():

stationDataCursor.toArray().then((docArr)=>{

    let newfeature = await docArr.map(async (x)=> await calcDSV.calcDSV(x))));


    res.json(newfeature);

})

或使 calcDSV() 返回新的承诺

    return  new Promise((rej, res)=>{
            resolve(featuresJSON);
     })

我希望看到所有网站在 HTTP 响应输出中添加了新功能。但大多数时候，我得到了 ReferenceError: 错误未定义。

我想我已经弄清楚了：

1. 毕竟，必须通过在这些函数前面添加 async 来使所有同步函数异步；

2. 在post router函数中重写这部分，特别是数组映射部分。我读自this https://futurestud.io/tutorials/node-js-how-to-run-an-asynchronous-function-in-array-map。并在map()一定要尝试……抓住……，否则行不通。

   await stationDataCursor.toArray().then(async (docArr)=>{
   
           const newfeature = await Promise.all(docArr.map(async function(x){
               try{
                   const feature = await calcDSV.calcDSV(x);
   
                   return feature
               } catch(err){
                   console.log("Error happened!!! ", err);
   
               }
   
           }));
   
           res.json(newfeature)
   
   })
   

希望能帮助到你。