异步/等待未按预期工作[重复]

Question

我的函数名为 createUser()：

const createUser = () => {
    return new Promise(async (resolve, reject) => {
        var data = await Home.findAll({ raw: true })
        await data.forEach(async (client) => {
            await postgresDB.createSchema(client.code).then(async () => {
                await Object.keys(postgresDB.models).forEach(async (currentItem) => {
                    await postgresDB.models[currentItem].schema(client.code).sync();
                });
            });
        });
        resolve('Postgres schema created')
    });
} 

我的 nodejs api：

exports.createBusiness = (req, res) => {
  const business = {
    name: req.body.name,
    code: req.body.code,
    email: req.body.email,
  };
  Business.create(business)
    .then((rawbusinessData) => {
      createUser() // this needs to completed full then only i need to move to below then function


        .then(() => {
          const businessData = rawbusinessData.get({ plain: true });
          const loginDetails = {
            username: 'sameer',
            password: encrypt('sameer'),
          };
          postgresDB.models.login.schema(businessData.code).create(loginDetails)
            .then((loginData) => {
              console.log('loginData:', loginData);
              return res.status(200).send(loginData);
            }).catch((err) => {
              console.log('error while create schema:', err);
            });
        });
    })
    .catch((err) => {
      console.log('err:', err);
    });
};

不知道是什么问题，苦苦挣扎了三天多。

我使用的是正确的语法吗？还是只使用 Promise 好？

Answer 1

forEach 返回 undefined, awaiting 不等待它迭代的异步函数。取而代之的是 map 到一系列承诺并使用 Promise.all 等待它们：

await Promise.all(Object.keys(postgresDB.models).map(async (currentItem) => {
      /*...*/
}));

---

在异步函数中另外使用new Promise 完全没有意义，如下：

const createUser = () => {
  return new Promise(async (resolve, reject) => {

其实可以：

async function createUser() {
  //...
}

然后只是return最后的结果。

---

你也必须

return User.create(loginDetails) 

这样它就会被链接到父 Promise 中。

---

我会怎么做：

async function createUser() {
  var data = await Home.findAll({ raw: true })
  await Promise.all(data.map(async (client) => {
    await postgresDB.createSchema(client.code)
    await Promise.all(Object.keys(postgresDB.models).map(currentItem => 

         postgresDB.models[currentItem].schema(client.code).sync();
    ));
  }));        
  return 'Postgres schema created';
} 

//------

exports.userSignup = async (req, res) => {
  try {
    await createUser();
    const loginDetails = {  username: 'stackoverflow' };
    const data = await User.create(loginDetails) 
    res.status(200).send(data);
  } catch(err) {
    console.log(err);
    res.status(500).send("")
 }
};

Answer 2

你不能像 await 和 forEach 这样 - 你需要将承诺映射到一个数组并使用 Promise.all 代替。此外，当您已经从另一个调用中获得 Promise 时，不要构造并返回 Promise - 相反，只需从其他调用中返回 Promise。

将两个forEachs 转换为Promise.all 调用。例如：

const createUser = async () => {
  var data = await Home.findAll({ raw: true });
  const clientPromises = data.map(async ({ code }) => {
    await postgresDB.createSchema(code);
    return Promise.all(postgresDB.models.map((currentItem) => (
      postgresDB.models[currentItem].schema(code).sync()
    )));
  });
  await Promise.all(clientPromises);
  console.log('Postgres schema created');
}