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

const resetlimitsforusers = async () => {
  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);
    }
  });
};