gpt4 book ai didi

javascript - 同步运行 Mongo find

转载 作者:行者123 更新时间:2023-12-02 20:50:15 25 4
gpt4 key购买 nike

我遇到一个问题,我的 csv 文件中有 20+k 行,我正在尝试根据包含 350k 文档的 Mongo DB 中匹配字段的文档来更新它们。

诀窍是我需要对匹配执行一些逻辑,然后重新更新 csv。

我正在使用 PapaParse 解析/解解析 csv 文件

做类似的事情来获得我所有的比赛

const file = fs.createReadStream('INFO.csv');
Papa.parse(file, {
header: true,
complete: function(row) {
getMatchesAndSave(row.data.map(el => { return el.fieldToMatchOn }));
}
});`

function getMatchesAndSave(fields) {
Order.find({fieldToMatchOn: { $in: fields}}, (err, results) => {
if (err) return console.error(err);
console.log(results);
});

}

这让我可以快速匹配。但是,我无法真正将数据合并回 csv 中,因为 csv 有一个 Mongo 不知道的唯一键列。

因此,所有数据实际上都取决于 csv 中的内容。

所以我想做这样的事情

`

const jsonToCSV = [];
for (let row of csvRows) {
db.Collection.find({fieldToMatchOn: row.fieldToMatchOn}, (err, result) => {
//Add extra data to row based on result
row.foo = result.foo;

//push to final output
jsonToCSV.push(row);
}
}
papa.unparse(jsonToCSV);
//save csv to file

上述实现的问题(尽管看起来效率极低) - 是 Find 调用是异步的,并且没有任何内容被推送到 jsonToCSV。

有什么建议吗?用 $in 解决这个问题是理想的,有什么方法可以访问 $in 中的当前元素(因此寻找迭代器)..这样我就可以处理它。

最佳答案

您可以尝试使用 async/await 来迭代 csvRows 数组,如下所示:

const search = async () => {
const jsonToCSV = await Promise.all(csvRows.map(async row => {
/* find returns a promise, so we can use await, but to use await is
mandatory use it inside an async function. Map function not returns a
promise, so this can be solve using Promise.all. */
try {
const result = await db.Collection.find({ fieldToMatchOn: row.fieldToMatchOn });
row.foo = result.foo;
return row;
} catch (e) {
// do somenthing if error
}
}));
papa.unparse(jsonToCSV);
}

// call search function
search();

检查这个https://flaviocopes.com/javascript-async-await-array-map以便更好地理解。

关于javascript - 同步运行 Mongo find,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61623515/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com