异步、瀑布问题

Question

在这里，我正在尝试检索所有对象并将它们推送到文件中。由于某种原因，当一条记录应包含更多对象时，只有一条记录被推送到文件中。甚至在执行之前就发送了响应。你能帮我解决这个问题，或者让我知道我哪里错了吗？这是我的代码：jsonexports.createjoson = (req, res) => {  const Responsearray = [];  async.waterfall(    [      function(waterfallCb) {        //  ... first function      },      function(results, waterfallCb1) {        //second function        async.eachLimit(          results,          100,          function(singleResult, eachCallback) {            async.waterfall(              [                async function(innerWaterfallCb) {                  try {                    NewsModel.find(                      { _id: singleResult.newsId }, // #individual article                      async (err, newsResult) => {                        if (err) {                          return innerWaterfallCb(                            // #displaying error                            "error in fetching news data"                          );                        }                        const map = new Map();                        for (const item of newsResult) {                          if (!map.has(item.source)) {                            map.set(item.source, true);                            Response = {                              newsId: item._id,                              title: item.title,                              comment: singleResult.comment                            };                          }                        }                        resPond = await Response;                        Responsearray.push(resPond);                        let data = JSON.stringify(Responsearray);                        await fs.writeFileSync("abc.json", data);                      }                    );                  } catch (error) {                    innerWaterfallCb(error);                  }                }              ],        

Answer 1

该代码存在许多问题：

1. fs.writeFileSync将覆盖文件，而不是附加到该文件，因此只有您写入的最后一个数据才会在 .此外，它不会返回 a，因此无需在其上使用。它同步运行，因此在完成之前不会返回（这就是其函数名称中的含义）。若要追加而不是覆盖文件，可以将标志选项设置为“a”以追加（默认值为“w”）。abc.jsonPromiseawaitSync

2. 似乎没有调用返回任何地方 - 仅在错误情况下。内部瀑布函数不应该被标记，因为它不需要真正做任何调用。但是您应该在写入文件后调用。innerWaterfallCb(null)asyncawaitreturn innerWaterfallCb(null)

3. 最好只是在外部瀑布的末尾收集数据并写入文件一次，而不是在内部瀑布的深处重复写入文件。responseArray

4. 变量应以小写字母开头（例如，因为大写的首字母通常表示类或模块。responseArrayResponseArray

5. 不要与异步模块（瀑布和每个Limit）混合使用。如果您使用的是正确的 Promises，那么就没有必要使用异步模块。完全删除的使用并重写以正确使用对象会更干净。async/awaitasync/awaitwaterfallPromise