开发一个cube.js schemaVersion 包装

2021-05-30 00:02

阅读:745

标签:hash   javascrip   doc   efault   pid   定义   keyword   local   gif   

默认dev环境schema 是不cache,所以会每次执行,生成环境是必须cach的,但是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){
  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也可以使用类似的方法

开发一个cube.js schemaVersion 包装

标签:hash   javascrip   doc   efault   pid   定义   keyword   local   gif   

原文地址:https://www.cnblogs.com/rongfengliang/p/14697834.html


评论


亲,登录后才可以留言!