Node.js+MySQL中如何用await处理多个Promise实现多任务同步

我来帮你梳理一下在Node.js + MySQL场景下，如何确保艺术家查询/创建、事件创建这两类异步操作全部完成后，再处理艺术家与事件的关联数据。核心思路是利用Promise.all()来批量等待所有异步任务，再执行后续遍历逻辑。

步骤拆解与代码示例 #

假设你已经有两个核心异步函数：

• getOrCreateArtist(artist)：查询数据库是否存在该艺术家，存在则返回ID，不存在则创建并返回新ID
• createEvent(eventData)：创建事件并返回生成的event_id

下面是完整的实现代码：

async function processArtistEventAssociation(artists, eventData) {
  try {
    // 1. 初始化Promise数组，用来存放所有需要等待的异步任务
    const asyncTasks = [];

    // 2. 添加所有艺术家的查询/创建任务到Promise数组
    if (artists.length > 0) {
      // 推荐用for...of遍历数组，避免for...in带来的原型链遍历问题
      for (const artist of artists) {
        asyncTasks.push(getOrCreateArtist(artist));
      }
    }

    // 3. 添加事件创建任务到Promise数组（和艺术家任务并行执行，提升效率）
    const eventCreationTask = createEvent(eventData);
    asyncTasks.push(eventCreationTask);

    // 4. 等待所有异步任务完成！这一步是关键
    // Promise.all会等待数组中所有Promise都resolve后，才会返回结果数组
    // 结果数组的顺序和你添加任务的顺序完全一致
    const taskResults = await Promise.all(asyncTasks);

    // 5. 从结果数组中分离出艺术家ID和事件ID
    const artistIds = taskResults.slice(0, artists.length);
    const eventId = taskResults[taskResults.length - 1];

    // 6. 现在可以安心遍历组合，处理关联数据了
    for (const artistId of artistIds) {
      // 执行插入关联数据的操作，比如：
      await db.query(
        'INSERT INTO artist_event (artist_id, event_id) VALUES (?, ?)',
        [artistId, eventId]
      );
      // 其他业务逻辑...
    }

    console.log('所有关联数据处理完成');
  } catch (error) {
    // 处理任何异步任务失败的情况，比如数据库错误
    console.error('处理过程出错:', error);
    // 这里可以添加事务回滚等容错逻辑（如果用了MySQL事务的话）
  }
}

关键注意点 #

• Promise.all()的特性：它会等待所有Promise成功完成，只要有一个Promise失败（reject），就会立即抛出错误。如果需要允许部分任务失败，你可以改用Promise.allSettled()，然后手动过滤成功的结果。
• 任务顺序的一致性：Promise.all()返回的结果数组顺序和你添加任务的顺序完全对应，所以你可以放心地通过切片来分离艺术家ID和事件ID。
• 避免for...in遍历数组：for...in是用来遍历对象属性的，遍历数组时可能会意外获取到原型链上的属性，for...of是更安全的数组遍历方式。
• 错误捕获：一定要用try/catch包裹await Promise.all()，否则异步任务的错误会导致整个函数抛出未捕获的异常。

内容的提问来源于stack exchange，提问作者bart great