首頁  >  文章  >  web前端  >  Cron 作業中聚合的力量和成本效益

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

Patricia Arquette
Patricia Arquette原創
2024-09-24 06:16:06783瀏覽

The Power of AGGREGATION in Cron Jobs and Cost-Effectiveness

在開發我的 SaaS 產品時,我發現,對於 10,000 個用戶,您每天需要 10,001 次查詢,以及常規資料庫查詢來重置積分或免費提示。透過智慧聚合,無論您有 10k 還是 100k 用戶,您都只需要 2 次查詢!

首先,讓我給您一些 MongoDB 生產資料庫的成本審查(10k 和 1 年):

正常方式,每日查詢:10,001
年度查詢:10,001 x 365 = 3,650,365 次查詢
年度費用:3,650,365 x 0.001 美元 = 3,650.37 美元

聚合方式,每日查詢:2
年度查詢:2 x 365 = 730 次查詢
年度費用:730 x 0.001 美元 = 0.73 美元

節省:3,650.37 - 0.73 = 3,649.64 美元(近 40 萬泰銖)

太棒了,現在看看傳統的查詢方法(為每個用戶進行一個查詢)

const resetLimitsForUsers = async () => {
  const users = await User.find({ /* conditions to select users */ });

  for (const user of users) {
    if (user.plan.remaining_prompt_count < 3 || user.plan.remaining_page_count < 3) {
      user.plan.remaining_prompt_count = 3;
      user.plan.total_prompt_count = 3;
      // Save updated plan
      await user.plan.save();
    }
  }
};

這裡,如果您有 10,000 個用戶,這會導致 10,001 個查詢(每個用戶 1 個,加上用於獲取用戶的初始查詢) - 這是巨大的..

現在是英雄條目,[看起來有點困難,但它可以節省大量的錢]

const resetPlanCounts = () => {
  cron.schedule('* * * * *', async () => {
    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 => user.planId);

      if (planIds.length > 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);
    }
  });
};

這就是您如何執行 cron 作業 [它在特定時間自動運行] 來更新所有 10k 用戶積分或限制,這可以在一年內節省超過 3600 美元。

作者,
姓名:Mahinur Ra​​hman
聯絡方式:dev.mahinur.rahman@gmail.com

以上是Cron 作業中聚合的力量和成本效益的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn