firebase 云计划功能无法正常工作

Question

我有firebase云计划功能。它在前两个时期运行良好，但随后就停止了。我的功能代码如下。我没有 javascript 经验。我的代码有错误吗？

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp(functions.config().firebase);

const database = admin.database();

// kapandığı zamandan 30 dk sonra devreye gir.
exports.soloTurnuvaTetikleyici = functions.pubsub.schedule("every 360 minutes").onRun((context) => {
  const peryot = 360;
  turnuvaGuncelle(peryot, "solo");
  return null;
});


function turnuvaGuncelle(peryot, oyunTipi) {
  const kapaliKalmaZamani = Math.floor(Math.random() * 60) + 90; // min 90 dk max 150 dk
  const kapanistanSonraBekle = 30; // wait after finish
  const now = new Date().getTime();

  const acilisZamani = new Date(now + kapaliKalmaZamani * 60000).getTime(); // open date
  const kapanisZamani = new Date(now + (peryot - kapanistanSonraBekle) * 60000).getTime(); // close date

  const tarihler = {
    acilis: acilisZamani,
    kapanis: kapanisZamani,
  };


  const diller = ["ar", "bj", "bn", "ca", "cs", "dz", "fr", "hr", "hu", "tr", "ch"];
  const ligler = ["1lig", "2lig", "3lig", "4lig", "5lig", "6lig", "7lig", "8lig", "9lig"];

  const ref = database.ref("/turnuvalar/");
  const updates = {};

  diller.forEach((dil) => {
    ligler.forEach((lig) => {
      updates[dil + "/" + lig + "/" + oyunTipi + "/info/"] = tarihler;
      updates[dil + "/" + lig + "/" + oyunTipi + "/matchmaking/"] = null;
    });
  });

  ref.update(updates);
}

我正在附上日志。 12:07:04.314 AM -> 工作正常

6:07:03,658 AM -> 工作正常

12:07:04.314 PM -> 没有打电话

当前日期 -> 下午 5:14:38.060

它应该每 6 小时运行一次，但它不起作用。你认为原因是什么？

Answer 1

您根本没有考虑您在云函数中调用的 Firebase 方法的异步特性。我不知道这是否是您问题的确切原因，但有一天它会以一种难以调试的方式产生问题，因为它会以“不稳定”的方式出现，如下所述。 正如您将在

官方 Firebase 视频系列中关于“JavaScript Promises”的三个视频中看到的那样，当所有异步操作完成时，您必须在后台触发的 Cloud Function 中返回 Promise 或值。这向平台表明它已完成，并且避免了云函数在异步操作完成之前终止。

在您的情况下，您不必等待异步 turnuvaGuncelle()

函数完成后再执行

return null;

。这向云函数平台表明它可以终止并清理您的函数，而无需等待异步 

turnuvaGuncelle()

 函数完成。

这可能会导致一些不稳定的行为，因为有时您的 Cloud Function 在异步更新操作完成之前终止，但有时，Cloud Function 平台不会立即终止 Function 并且异步操作可以完成。

您需要按如下方式调整您的代码（我们使用

async/await

）：

// kapandığı zamandan 30 dk sonra devreye gir.
exports.soloTurnuvaTetikleyici = functions.pubsub.schedule("every 360 minutes").onRun(async (context) => {
    const peryot = 360;
    await turnuvaGuncelle(peryot, "solo");
    return null;
});


async function turnuvaGuncelle(peryot, oyunTipi) {
    const kapaliKalmaZamani = Math.floor(Math.random() * 60) + 90; // min 90 dk max 150 dk
    const kapanistanSonraBekle = 30; // wait after finish
    const now = new Date().getTime();

    const acilisZamani = new Date(now + kapaliKalmaZamani * 60000).getTime(); // open date
    const kapanisZamani = new Date(now + (peryot - kapanistanSonraBekle) * 60000).getTime(); // close date

    const tarihler = {
        acilis: acilisZamani,
        kapanis: kapanisZamani,
    };

    const diller = ["ar", "bj", "bn", "ca", "cs", "dz", "fr", "hr", "hu", "tr", "ch"];
    const ligler = ["1lig", "2lig", "3lig", "4lig", "5lig", "6lig", "7lig", "8lig", "9lig"];

    const ref = database.ref("/turnuvalar/");
    const updates = {};

    diller.forEach((dil) => {
        ligler.forEach((lig) => {
            updates[dil + "/" + lig + "/" + oyunTipi + "/info/"] = tarihler;
            updates[dil + "/" + lig + "/" + oyunTipi + "/matchmaking/"] = null;
        });
    });

    await ref.update(updates);
}