zoukankan      html  css  js  c++  java
  • 开发一个cube.js schemaVersion 包装

    默认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也可以使用类似的方法

  • 相关阅读:
    Go 打印出结构化结构体
    GOPROXY设置
    python判断链表是否有环
    单链表python和go的代码
    mongo索引
    python修改srt字幕的时间轴
    python各个版本的排序
    mac使用python识别图形验证码
    selenium运行js代码笔记
    布隆过滤器
  • 原文地址:https://www.cnblogs.com/rongfengliang/p/14697834.html
Copyright © 2011-2022 走看看