我们正在开发一个使用新的 firebase 云功能的应用程序。当前正在发生的事情是将事务放入队列节点中。然后该函数删除该节点并将其放入正确的节点中。由于能够离线工作,因此已经实施了这一点。
我们当前的问题是函数的速度。该函数本身大约需要 400 毫秒,所以没关系。但有时函数需要很长时间(大约 8 秒),而条目已经添加到队列中。
我们怀疑服务器启动需要时间,因为当我们在第一次之后再次执行该操作时。它需要更少的时间。
有没有办法解决这个问题?在这里,我添加了我们函数的代码。我们怀疑它没有任何问题,但我们添加了它以防万一。
const functions = require('firebase-functions'); const admin = require('firebase-admin'); const database = admin.database(); exports.insertTransaction = functions.database .ref('/userPlacePromotionTransactionsQueue/{userKey}/{placeKey}/{promotionKey}/{transactionKey}') .onWrite(event => { if (event.data.val() == null) return null; // get keys const userKey = event.params.userKey; const placeKey = event.params.placeKey; const promotionKey = event.params.promotionKey; const transactionKey = event.params.transactionKey; // init update object const data = {}; // get the transaction const transaction = event.data.val(); // transfer transaction saveTransaction(data, transaction, userKey, placeKey, promotionKey, transactionKey); // remove from queue data[`/userPlacePromotionTransactionsQueue/${userKey}/${placeKey}/${promotionKey}/${transactionKey}`] = null; // fetch promotion database.ref(`promotions/${promotionKey}`).once('value', (snapshot) => { // Check if the promotion exists. if (!snapshot.exists()) { return null; } const promotion = snapshot.val(); // fetch the current stamp count database.ref(`userPromotionStampCount/${userKey}/${promotionKey}`).once('value', (snapshot) => { let currentStampCount = 0; if (snapshot.exists()) currentStampCount = parseInt(snapshot.val()); data[`userPromotionStampCount/${userKey}/${promotionKey}`] = currentStampCount + transaction.amount; // determines if there are new full cards const currentFullcards = Math.floor(currentStampCount > 0 ? currentStampCount / promotion.stamps : 0); const newStamps = currentStampCount + transaction.amount; const newFullcards = Math.floor(newStamps / promotion.stamps); if (newFullcards > currentFullcards) { for (let i = 0; i < (newFullcards - currentFullcards); i++) { const cardTransaction = { action: "pending", promotion_id: promotionKey, user_id: userKey, amount: 0, type: "stamp", date: transaction.date, is_reversed: false }; saveTransaction(data, cardTransaction, userKey, placeKey, promotionKey); const completedPromotion = { promotion_id: promotionKey, user_id: userKey, has_used: false, date: admin.database.ServerValue.TIMESTAMP }; const promotionPushKey = database .ref() .child(`userPlaceCompletedPromotions/${userKey}/${placeKey}`) .push() .key; data[`userPlaceCompletedPromotions/${userKey}/${placeKey}/${promotionPushKey}`] = completedPromotion; data[`userCompletedPromotions/${userKey}/${promotionPushKey}`] = completedPromotion; } } return database.ref().update(data); }, (error) => { // Log to the console if an error happened. console.log('The read failed: ' + error.code); return null; }); }, (error) => { // Log to the console if an error happened. console.log('The read failed: ' + error.code); return null; }); }); function saveTransaction(data, transaction, userKey, placeKey, promotionKey, transactionKey) { if (!transactionKey) { transactionKey = database.ref('transactions').push().key; } data[`transactions/${transactionKey}`] = transaction; data[`placeTransactions/${placeKey}/${transactionKey}`] = transaction; data[`userPlacePromotionTransactions/${userKey}/${placeKey}/${promotionKey}/${transactionKey}`] = transaction; }
火力基地在这里
听起来您正在经历该功能的所谓冷启动。
当您的函数在一段时间内未执行时,Cloud Functions 会将其置于使用较少资源的模式,这样您就无需为未使用的计算时间付费。然后,当您再次点击该功能时,它会从此模式恢复环境。恢复所需的时间包括固定成本(例如恢复容器)和部分可变成本(例如,如果您使用大量节点模块,可能需要更长的时间)。
我们会持续监控这些操作的性能,以确保开发人员体验和资源使用之间的最佳组合。因此,预计这些时间会随着时间的推移而改善。
好消息是你应该只在开发过程中体验到这一点。一旦你的函数在生产环境中被频繁触发,它们很可能几乎不会再次冷启动,特别是如果它们有稳定的流量。但是,如果某些功能倾向于看到流量高峰,您仍然会看到每个高峰的冷启动。在这种情况下,您可能需要考虑minInstances设置以始终保持一定数量的延迟关键函数实例温暖。
minInstances