Nodejs 请问怎么在主调方法内获取异步请求的回调函数的返回值？如下：

在Node.js中，异步操作（如网络请求）无法直接在回调函数外同步获取返回值。这是因为JavaScript的事件循环机制决定了异步代码不会阻塞主线程。为了解决这个问题，可以使用async/await语法来简化异步操作的处理。

以下是修改后的代码示例：

const fs = require('fs');
const path = require('path');
const csv = require('csv-parser');
const request = require('request');

const csvpath = "C:/Users/name/Desktop/address.csv";

async function processCSV() {
    const results = [];

    await new Promise((resolve, reject) => {
        fs.createReadStream(csvpath)
            .pipe(csv({ headers: true }))
            .on('data', (row) => {
                if (!row || row.length < 3) return; // 跳过不完整的行
                const location = `${row.lat.trim()},${row.lng.trim()}`;
                request.get({ url: `http://api.map.baidu.com/geocoder/v2/?ak=xxxxxxxxx&output=json&pois=1&location=${location}` }, (error, response, body) => {
                    if (!error && response.statusCode === 200) {
                        try {
                            const result = JSON.parse(body);
                            if (result.status === 0) {
                                results.push({
                                    index: row.index,
                                    lat: result.location.lat,
                                    lng: result.location.lng,
                                    address: result.formatted_address,
                                    city: result.addressComponent.city,
                                    district: result.addressComponent.district,
                                    province: result.addressComponent.province,
                                    street: result.addressComponent.street,
                                    street_number: result.addressComponent.street_number,
                                    pois: result.pois.map(poi => ({
                                        name: poi.name,
                                        poiType: poi.poiType,
                                        addr: poi.addr,
                                        point: `${poi.point.x},${poi.point.y}`,
                                        distance: poi.distance
                                    }))
                                });
                            }
                        } catch (e) {
                            console.error(`Error parsing response: ${body}`);
                        }
                    } else {
                        console.error(`Request error: ${error} - Status code: ${response.statusCode}`);
                    }
                });
            })
            .on('end', () => {
                resolve();
            })
            .on('error', (err) => {
                reject(err);
            });
    });

    // 将结果写入文件
    fs.writeFileSync('./result.csv', results.map(result => [
        result.index,
        result.lat,
        result.lng,
        result.address,
        result.city,
        result.district,
        result.province,
        result.street,
        result.street_number,
        ...result.pois.map(poi => [poi.name, poi.poiType, poi.addr, poi.point, poi.distance])
    ].join(',')));
}

processCSV();

解释：

1. async 函数：将处理逻辑封装在一个异步函数中。
2. await 关键字：用于等待异步操作完成。
3. Promise：将传统的回调式API转换为支持await的Promise形式。
4. fs 模块：用于读取和写入文件。
5. request 模块：用于发送HTTP请求。

这样可以确保所有的异步请求都完成后再进行后续处理，最终将结果保存到result.csv文件中。