Cron 作业中聚合的力量和成本效益

const resetlimitsforusers = async () =&gt; {  const users = await user.find({ /* conditions to select users */ });  for (const user of users) {    if (user.plan.remaining_prompt_count <p>这里，如果您有 10,000 个用户，这会导致 10,001 个查询（每个用户 1 个，加上用于获取用户的初始查询） - 这是巨大的..</p><p>现在是英雄条目，[看起来有点困难，但它可以节省大量的钱]<br></p><pre class="brush:php;toolbar:false">const resetPlanCounts = () =&gt; {  cron.schedule('* * * * *', async () =&gt; {    try {      const twoMinutesAgo = new Date(Date.now() - 2 * 60 * 1000); // 2 minutes ago      const usersWithRegisteredPlan = await User.aggregate([        {          $match: {            createdAt: { $lte: twoMinutesAgo },            plan: { $exists: true }          }        },        {          $lookup: {            from: 'plans',            localField: 'plan',            foreignField: '_id',            as: 'planDetails'          }        },        {          $unwind: '$planDetails'        },        {          $match: {            'planDetails.name': 'Registered',            $or: [              { 'planDetails.remaining_prompt_count': { $lt: 3 } },              { 'planDetails.remaining_page_count': { $lt: 3 } }            ]          }        },        {          $project: {            planId: '$planDetails._id'          }        }      ]);      const planIds = usersWithRegisteredPlan.map(user =&gt; user.planId);      if (planIds.length &gt; 0) {        const { modifiedCount } = await Plan.updateMany(          { _id: { $in: planIds } },          { $set: { remaining_prompt_count: 3, total_prompt_count: 3, remaining_page_count: 3, total_page_count: 3 } }        );        console.log(`${modifiedCount} plans reset for "Registered" users.`);      } else {        console.log('No plans to reset for today.');      }    } catch (error) {      console.error('Error resetting plan counts:', error);    }  });};