ekzyis
/
stacker.news
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use greedy connection from view refreshes

This commit is contained in:
keyan 2024-01-25 18:09:33 -06:00
parent 5086c2036d
commit 6179d14a68
1 changed files with 22 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
worker/views.js
View File

@ -1,16 +1,32 @@
import { PrismaClient } from '@prisma/client'
const viewPrefixes = ['reg_growth', 'spender_growth', 'item_growth', 'spending_growth',
'stackers_growth', 'stacking_growth', 'user_stats']
// this is intended to be run everyday after midnight CT
export async function views ({ data: { period } = { period: 'days' }, models }) {
for (const view of viewPrefixes) {
await models.$queryRawUnsafe(`REFRESH MATERIALIZED VIEW CONCURRENTLY ${view}_${period}`)
export async function views ({ data: { period } = { period: 'days' } }) {
// grab a greedy connection
const models = new PrismaClient()
try {
for (const view of viewPrefixes) {
await models.$queryRawUnsafe(`REFRESH MATERIALIZED VIEW CONCURRENTLY ${view}_${period}`)
}
} finally {
await models.$disconnect()
}
}
// this should be run regularly ... like, every 5 minutes
export async function rankViews ({ models }) {
for (const view of ['zap_rank_personal_view']) {
await models.$queryRawUnsafe(`REFRESH MATERIALIZED VIEW CONCURRENTLY ${view}`)
export async function rankViews () {
// grab a greedy connection
const models = new PrismaClient()
try {
for (const view of ['zap_rank_personal_view']) {
await models.$queryRawUnsafe(`REFRESH MATERIALIZED VIEW CONCURRENTLY ${view}`)
}
} finally {
await models.$disconnect()
}
}