جدولة الدوال

إذا أردت جدولة الدوال ليتم تشغيلها في أوقات محدّدة، استخدِم معالج onSchedule الذي يوفّره firebase-functions/v2/scheduler. تستخدم هذه الدوال Cloud Scheduler لاستدعاء منطق الدالة في الأوقات أو الفواصل الزمنية التي تحدّدها.

قبل البدء

على الرغم من أنّ الدوال المُجدوَلة تتم فوترتها، يمكنك توقُّع أن تكون التكلفة الإجمالية معقولة، لأنّ كل مهمة Cloud Scheduler تكلّف 0.10 دولار أمريكي شهريًا، وهناك حدّ أقصى مسموح به يبلغ ثلاث مهام لكل حساب على Google بدون أي رسوم. استخدِم حاسبة الأسعار في خطة Blaze لإنشاء تقدير للتكلفة استنادًا إلى الاستخدام المتوقّع.

يجب تفعيل واجهة برمجة التطبيقات Cloud Scheduler لمشروعك. من المفترض أن تكون هذه الميزة مفعَّلة لمعظم مشاريع Firebase، ويمكنك التحقّق من ذلك في وحدة تحكّم Google Cloud.

كتابة دالة مُجدوَلة

في Cloud Functions for Firebase، يتوفّر منطق الجدولة في رمز الدوال، بدون متطلبات خاصة لوقت النشر. على سبيل المثال، لتنظيف حسابات المستخدمين غير النشطة مرة واحدة يوميًا، يمكنك كتابة دالة تبدأ بعبارات الاستيراد التالية:

Node.js

// The Cloud Functions for Firebase SDK to set up triggers and logging.
const {onSchedule} = require("firebase-functions/scheduler");
const {logger} = require("firebase-functions");

// The Firebase Admin SDK to delete inactive users.
const {initializeApp} = require("firebase-admin/app");
const {getAuth} = require("firebase-admin/auth");
initializeApp();

// The es6-promise-pool to limit the concurrency of promises.
const PromisePool = /** @type {PromisePoolConstructor} */ (
  require("es6-promise-pool")
);
// Maximum concurrent account deletions.
const MAX_CONCURRENT = 3;

Python

# The Cloud Functions for Firebase SDK to set up triggers and logging.
from firebase_functions import scheduler_fn

# The Firebase Admin SDK to delete users.
import firebase_admin
from firebase_admin import auth

firebase_admin.initialize_app()

بعد ذلك، يمكنك استخدام onSchedule لبدء مهمة Cloud Scheduler:

Node.js

// Run once a day at midnight, to clean up the users
// Manually run the task here https://console.cloud.google.com/cloudscheduler
exports.accountcleanup = onSchedule("every day 00:00", async (event) => {
  // Fetch all user details.
  const inactiveUsers = await getInactiveUsers();

  // Use a pool so that we delete maximum `MAX_CONCURRENT` users in parallel.
  const promisePool = new PromisePool(
      () => deleteInactiveUser(inactiveUsers),
      MAX_CONCURRENT,
  );
  await promisePool.start();

  logger.log("User cleanup finished");
});

Python

# Run once a day at midnight, to clean up inactive users.
# Manually run the task here https://console.cloud.google.com/cloudscheduler
@scheduler_fn.on_schedule(schedule="every day 00:00")
def accountcleanup(event: scheduler_fn.ScheduledEvent) -> None:
    """Delete users who've been inactive for 30 days or more."""
    user_page: auth.ListUsersPage | None = auth.list_users()
    while user_page is not None:
        inactive_uids = [
            user.uid for user in user_page.users if is_inactive(user, timedelta(days=30))
        ]
        auth.delete_users(inactive_uids)
        user_page = user_page.get_next_page()

يتوافق Cloud Scheduler مع كل من صيغة Unix Crontab وصيغة App Engine. على سبيل المثال، لاستخدام Crontab، يمكنك تنفيذ ما يلي:

Node.js

exports.scheduledFunctionCrontab = onSchedule("5 11 * * *", async (event) => {
  // ...
});

Python

@scheduler_fn.on_schedule(schedule="5 11 * * *")

نشر دالة مجدوَلة

عند نشر دالة مجدوَلة، يتم تلقائيًا إنشاء وظيفة مجدوَلة ودالة HTTP. تعرض واجهة سطر الأوامر في Firebase اسم الدالة، ويمكنك الاطّلاع على المهمة والدالة في وحدة تحكّم Google Cloud. تتم تسمية الموضوع وفقًا للاصطلاح التالي:

firebase-schedule-function_name-region

على سبيل المثال:

firebase-schedule-accountcleanup-us-east1.

في الوقت المحدّد، يستدعي حساب خدمة Compute Engine التلقائي دالة HTTP المرتبطة. وهذا يعني أنّ وظيفة Cloud Scheduler المرتبطة فقط هي التي تملك الإذن لتشغيل الدالة.