alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update: dynamic delay factor for snapshotMilestoneVideo

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-22 00:40:00 +08:00
parent fabb77d98d
commit 1895d601d9
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/mq/exec/snapshotTick.ts
View File

@ -106,6 +106,8 @@ export const snapshotTickWorker = async (_job: Job) => {
} }
}; };
const log = (a: number, b: number = 10) => Math.log(a) / Math.log(b);
export const takeSnapshotForMilestoneVideoWorker = async (job: Job) => { export const takeSnapshotForMilestoneVideoWorker = async (job: Job) => {
const client = await db.connect(); const client = await db.connect();
await setSnapshotScheduled(job.data.aid, true, 20 * 60); await setSnapshotScheduled(job.data.aid, true, 20 * 60);
@ -128,6 +130,7 @@ export const takeSnapshotForMilestoneVideoWorker = async (job: Job) => {
return; return;
} }
let eta = await getShortTermEtaPrediction(client, aid); let eta = await getShortTermEtaPrediction(client, aid);
let factor = 3;
if (eta === null) { if (eta === null) {
const DELTA = 0.001; const DELTA = 0.001;
const intervalSeconds = (Date.now() - parseTimestampFromPsql(lastSnapshoted)) / SECOND; const intervalSeconds = (Date.now() - parseTimestampFromPsql(lastSnapshoted)) / SECOND;
@ -135,8 +138,9 @@ export const takeSnapshotForMilestoneVideoWorker = async (job: Job) => {
const incrementSpeed = viewsIncrement / (intervalSeconds + DELTA); const incrementSpeed = viewsIncrement / (intervalSeconds + DELTA);
const viewsToIncrease = nextMilestone - stat.views; const viewsToIncrease = nextMilestone - stat.views;
eta = viewsToIncrease / (incrementSpeed + DELTA); eta = viewsToIncrease / (incrementSpeed + DELTA);
factor = log(2.97 / log(viewsToIncrease + 1), 1.14);
} }
const scheduledNextSnapshotDelay = eta * SECOND / 3; const scheduledNextSnapshotDelay = eta * SECOND / factor;
const maxInterval = 60 * MINUTE; const maxInterval = 60 * MINUTE;
const minInterval = 1 * SECOND; const minInterval = 1 * SECOND;
const delay = truncate(scheduledNextSnapshotDelay, minInterval, maxInterval); const delay = truncate(scheduledNextSnapshotDelay, minInterval, maxInterval);