毎日のスケジュールされた機能でこの2つのエラーが発生しています。毎日、給料日かどうかを確認し、各ユーザーの負債に対応する金額を追加しようとしています。
Error: Process exited with code 16
at process.on.code (invoker.js:271)
at process.emit (events.js:198)
at process.EventEmitter.emit (domain.js:448)
at process.exit (per_thread.js:168)
at Object.logAndSendError (/layers/google.nodejs.functions-framework/functions-framework/node_modules/@google-cloud/functions-framework/build/src/logger.js:37)
at process.on.err (invoker.js:268)
at process.emit (events.js:198)
at process.EventEmitter.emit (domain.js:448)
at emitPromiseRejectionWarnings (internal/process/promises.js:140)
at process._tickCallback (next_tick.js:69)
そして：
Error: 4 DEADLINE_EXCEEDED: Deadline exceeded
at Object.callErrorFromStatus (/workspace/node_modules/@grpc/grpc-js/build/src/call.js:30)
at Object.onReceiveStatus (/workspace/node_modules/@grpc/grpc-js/build/src/client.js:175)
at Object.onReceiveStatus (/workspace/node_modules/@grpc/grpc-js/build/src/client-interceptors.js:341)
at Object.onReceiveStatus (/workspace/node_modules/@grpc/grpc-js/build/src/client-interceptors.js:304)
at Http2CallStream.outputStatus (/workspace/node_modules/@grpc/grpc-js/build/src/call-stream.js:116)
at Http2CallStream.maybeOutputStatus (/workspace/node_modules/@grpc/grpc-js/build/src/call-stream.js:155)
at Http2CallStream.endCall (/workspace/node_modules/@grpc/grpc-js/build/src/call-stream.js:141)
at Http2CallStream.cancelWithStatus (/workspace/node_modules/@grpc/grpc-js/build/src/call-stream.js:457)
at Timeout.DeadlineFilter.timer.setTimeout (deadline-filter.js:59)
at ontimeout (timers.js:436)
これは私の機能です：
「firebase-functions」から関数として*をインポートします。import * as admin from "firebase-admin";
/// Checks every day if the debt pay day is equal to the setting and add the corresponding amount to the debt
export const checkForMonthChange = functions.pubsub
.schedule("every day 00:00")
.onRun(async (context) => {
try {
const db = admin.firestore();
const dayOfMonth = admin.firestore.Timestamp.now().toDate().getDate();
const neighborhoods = await db.collection("_settings").get();
const promises = [];
neighborhoods.forEach(async (doc) => {
const dayToPay = doc.data().day_of_month_to_pay;
if (dayOfMonth === dayToPay) {
const neighborhoodToUpdateName = doc.ref.id;
const neighborhoodToUpdate = await db
.collection(neighborhoodToUpdateName)
.get();
neighborhoodToUpdate.forEach(async (neighbor) => {
const userPlan = await neighbor.data().plan;
const amountToAdd = (
await db
.collection("_settings")
.doc(neighborhoodToUpdateName)
.collection("payment_plans")
.doc(userPlan)
.get()
).data().monthly_pay;
console.log(userPlan);
console.log(amountToAdd);
promises.push(
neighbor.ref.update({
debt: neighbor.data()?.debt + amountToAdd,
})
);
});
}
});
if (Promise.all.length !== 0) {
console.log(`Debt Increased Day of Month: ${dayOfMonth}`);
return Promise.all(promises);
} else {
return null;
}
} catch (error) {
console.log(`Error in every day schedule: ${error}`);
}
});
私が間違っていることは何ですか？
編集：コンソールにこれらの2つのログが表示されています
console.log(userPlan);
console.log(amountToAdd);
前もって感謝します
awaitforEachラムダ関数内での使用は、期待どおりに機能しません。ループの実行を一時停止することはありません。今のように、forEachループは、近隣ごとに1回ずつ、すぐに何度も実行されます。コードはpromises（ループが実行される前に）配列をチェックし続けます。配列は常に空になります。
forEachループ内のすべての非同期作業が実際に完了した後にのみ解決されるpromiseをコードが返すことを確認する必要があります。それについての完全な議論については、この他の質問を参照してください。この問題は、forEachが非同期として宣言された関数を受け入れ、すぐにpromiseを返すという事実によるものです。
または、forEachの使用を避け、代わりに、より大きい関数の非同期コンテキストでコードを実行するforループを使用して、期待どおりにawaitを使用することもできます。
for (const doc of neighborhoods.docs) {
// use await here to pause the entire function
}
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加