链接多个 Promise，使用 map 循环数组并创建 mongoose 文档？

Question

我正在使用getPeople() 从数据库中检索人员列表。一旦我以res 收到它们，我想准备将它们存储在我的本地 mongodb 如果它们不存在。有时res 中有重复的条目（对于一个id）。我的问题是它没有等待Person.create(pers) 完成，继续搜索这个id 是否已经在mongodb 中，找不到任何因为Person.create(pers) 仍在创建它并开始第二个Person.create(pers)..

this.getPeople()
  .then(res => {
    return Promise.all(res.map(pers => {
      pers.birthday = df(pers.birthday, 'dd.mm.yyyy')
      pers.pickedUp = false
      console.log(pers.id)
      return Person
        .find({ id: pers.id })
        .exec()
        .then(found => {
          if (found === undefined || found.length == 0)
            return pers
        })
        .then(pers => {
          return Person
            .create(pers)
            .then(console.log('created'))
            .catch(err => console.log(err))
        })
    }))
  }).catch(err => console.log(err))

我希望控制台输出是这样的：

940191
created
940191
created

相反，我得到了这个：

940191
940191
created
created

Answer 1

那是因为 Promise.all 只是在等待你的所有承诺 mapping。它不保证承诺的解决顺序。

如果您想按顺序处理res-array 的元素，您可以简单地将for .. of 循环与async/await 结合使用（请注意，这仍然需要一些错误处理，但它应该给你一些东西开始）：

async function getPeopleAndCreateIfNotExisting() {
    const persons = [];
    const res = await this.getPeople();

    for (const pers of res) {    
        pers.birthday = df(pers.birthday, 'dd.mm.yyyy');
        pers.pickedUp = false;
        console.log(pers.id)
        const found = await Person
            .find({ id: pers.id }).exec();
        if (found) {
            persons.push(pers);
        } else {
            persons.push(await Person.create(pers));
        }
    }
    return person;
}