javascript - Firebase Cloud Functions 超时的效率

Question

我有一个函数，每次将新元素添加到数据库时都会发送电子邮件，如下所示:

export const onWorkCreation = functions.database.ref('/Works/{workId}').onCreate(async (snapshot, context) => {
    const work = snapshot.val();
    // const emails = ['email1@email.com', 'email2@email.com', 'email3@email.com'];
    // TODO sprawdz z jakiej kategorii zadanie, wyslij do uzytkownikow ktorzy maja te kategorie + link do deaktywacji emaili.
    let calls = [];
    const persons = admin.database().ref('Users').orderByChild('userType').equalTo('person').once('value').then(r => r.val()).catch(err => console.log(1, err));
    const companies = admin.database().ref('Users').orderByChild('userType').equalTo('company').once('value').then(r => r.val()).catch(err => console.log(2, err));
    const undefineds = admin.database().ref('Users').orderByChild('userType').equalTo('undefined').once('value').then(r => r.val()).catch(err => console.log(3, err));
    calls.push(persons, companies, undefineds);

    let users = await Promise.all(calls).catch(err => console.log(4, err));
    users = [...arrayFromObject(users[0]), ...arrayFromObject(users[1]), ...arrayFromObject(users[2])];
    users.filter(u => u.receivesNotifications === undefined || u.receivesNotifications === true);
    const usersIds = [];
    for (const i in users) {
        const user = users[i];
        if (user.testInfo[work.category] !== undefined && user.testInfo[work.category.toLowerCase()].status.toLowerCase() === 'approved' && user.receivesNotifications !== false) {
            usersIds.push(user.id);
        } else {
            // console.log(work);
            // console.log(user.testInfo[work.category]);
            // console.log(work.category);
            // console.log(2, user.testInfo[work.category] !== undefined, 3, user.testInfo[work.category] !== undefined && user.testInfo[work.category.toLowerCase()].status.toLowerCase() === 'approved', 4, user.receivesNotifications !== false)
        }
    }
    calls = [];
    for (const i in usersIds) {
        calls.push(0);
        try {
            calls[i] = await admin.auth().getUser(usersIds[i]).then(r => r).catch(err => console.log(5, err, usersIds[i]));
        } catch (e) {
            console.log('user', usersIds[i]);
        }
    }
    users = await Promise.all(calls).catch(err => console.log(6, err));
    users = arrayFromObject(users);
    console.log('users', users);
    const usersDetails = [];
    for (const i in users) {
        const user = {
            email: users[i].email,
            id: users[i].uid,
        };
        usersDetails.push(user);
    }
    calls = [];
    const mailTransport = nodemailer.createTransport({
        service: 'gmail',
        auth: {
            user: 'USER',
            pass: 'PASS'
        },
    });
    for (const i in usersDetails) {
        const user = usersDetails[i];
        calls.push(mailTransport.sendMail({
            from: `ZdajTo <noreply@zdajto.com>`,
            to: user.email,
            subject: `Dostepne sa nowe zadania!`,
            html: `<p>Hej! Sprawdz aplikacje ZdajTo! Dostepne sa nowe zadania z kategorii ${work.category}! Aby zrezygnowac z otrzymywania emaili kliknij w <a href="https://us-central1-uczsieapp.cloudfunctions.net/adminHelper/cancelEmailSubscription/${user.id}" target="_blank">ten link</a></p>`,
        }).then(() => null).catch(err => console.log(7, err, user.email)));
    }
    return Promise.all(calls).then(() => console.log('Emails sent')).catch(err => console.log(8, err));
});

代码很多，但简而言之，它的作用就是抓取某些用户的电子邮件并将电子邮件发送到这些地址。

现在。每次创建新的工作子项时我都会启动它。有没有办法检查 child 是否在数据库中挂起超过 5 分钟？

我想要实现的目标:

如果work的属性(available)在5分钟内没有改变，我想再次发送电子邮件。我可以通过启动超时循环来实现它，但我希望有更好的方法。

Answer 1

为此，我将使用一个 CRON 函数，该函数根据状态和创建时间查询工作。 (添加工作元素时，您需要填充 createTime 值。)执行 CRON 函数的最简单方法是使用 Azure Functions，但是，您还可以查看 GCP/firebase 原生的其他选项。