默认dev环境schema 是不cache，所以会每次执行，生成环境是必须cache的，但是cache就有schemaversion 的问题
所以基于cache-manager 包装了一个cache处理的，代码很简单，但是可以减少对于schemaversion的时间消耗
参考包装代码
schemaversion.js
const cacheManager = require('cache-manager');
const crypto = require('crypto');
const redisStore = require('cache-manager-ioredis');
const redisCache = cacheManager.caching({
store: redisStore,
host: process.env.REDIS_HOST || "localhost", // default value
port: process.env.REDIS_PORT? parseInt(process.env.REDIS_PORT):6379, // default value
db: 0,
password: process.env.REDIS_PASS || null,
ttl: process.env.REDIS_TTL? parseInt(process.env.REDIS_TTL):10
});
function pause(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
module.exports = {
schemaVersion: async (securityContext,func)=> {
let cachekey = `SCHEMAVERSION_${crypto.createHash('md5').update(JSON.stringify(securityContext)).digest('hex')}`
return redisCache.wrap(cachekey, function() {
return func(securityContext);
});
},
pause:pause
}
- 说明
使用很简单，引用模块，同时自己包装一个promise 的函数就可以，需要传递的参数为securityContext 以及一个自定义的函数
参考使用
// Cube.js configuration options: https://cube.dev/docs/config
const {CubejsHandlerError} = require("@cubejs-backend/api-gateway")
=const index = require("./index")
const {pause,schemaVersion} = require("./schemaversion")
async function fetchVersion(securityContext){
await pause(3000)
console.log("call version")
return `"dalong"---${parseInt(Math.random()*100)}`
}
module.exports = {
schemaVersion: async ({ securityContext }) =>{
return schemaVersion(securityContext,fetchVersion)
},
contextToAppId: ({ securityContext }) => {
return `CUBEJS_APP_${securityContext.user_id}`
}
};
说明
以上代码很简单，对于cache key 可以自己调整，同时对于scheduledRefreshContexts也可以使用类似的方法