กำหนดเวลาฟังก์ชัน


หากต้องการตั้งเวลาให้ฟังก์ชันทำงานตามเวลาที่กำหนด ให้ใช้เครื่องจัดการ onSchedule จาก firebase-functions/v2/scheduler ฟังก์ชันเหล่านี้ใช้ Cloud Scheduler เพื่อเรียกใช้ตรรกะฟังก์ชันตามเวลาหรือช่วงเวลาที่คุณกำหนด

ก่อนเริ่มต้น

หากต้องการใช้โซลูชันนี้ในโปรเจ็กต์ Firebase โปรเจ็กต์ของคุณต้องใช้แพ็กเกจราคา Blaze หากยังไม่ได้ใช้แพ็กเกจ Blaze ให้อัปเกรดแพ็กเกจราคา

แม้ว่าจะต้องมีการเรียกเก็บเงิน แต่ค่าใช้จ่ายโดยรวมจะอยู่ในระดับที่คุณจัดการได้ เนื่องจากCloud Schedulerงานแต่ละรายการมีค่าใช้จ่าย $0.10 (USD) ต่อเดือน และคุณมีสิทธิ์ใช้งานได้ 3 รายการต่อบัญชี Google โดยไม่มีค่าใช้จ่าย ใช้เครื่องคำนวณราคาของ Blaze เพื่อสร้างต้นทุนโดยประมาณตามการใช้งานที่คาดการณ์

คุณต้องเปิดใช้ Cloud Scheduler API สำหรับโปรเจ็กต์ ฟีเจอร์นี้ควรเปิดใช้แล้วสำหรับโปรเจ็กต์ 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/v2/scheduler");
const {logger} = require("firebase-functions");

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

// The es6-promise-pool to limit the concurrency of promises.
const PromisePool = require("es6-promise-pool").default;
// Maximum concurrent account deletions.
const MAX_CONCURRENT = 3;
index.js

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()
main.py

จากนั้น คุณสามารถใช้ 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");
});
index.js

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()
main.py

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 CLI จะแสดงชื่อฟังก์ชัน และคุณสามารถดูงานและฟังก์ชันในคอนโซล Google Cloud หัวข้อจะตั้งชื่อตามรูปแบบต่อไปนี้

firebase-schedule-function_name-region

เช่น

firebase-schedule-accountcleanup-us-east1.

เมื่อถึงเวลาที่กำหนด บัญชีบริการ Compute เริ่มต้นจะเรียกใช้ฟังก์ชัน HTTP ที่เชื่อมโยง ซึ่งหมายความว่ามีเพียงCloud Scheduler งานที่เกี่ยวข้องเท่านั้นที่มีสิทธิ์เรียกใช้ฟังก์ชัน