zoukankan      html  css  js  c++  java
  • 在 SAP Kyma 上使用 Redis 服务

    链接:https://developers.sap.com/tutorials/cp-kyma-redis-function.html

    本地文件:C:Code eferenceCodeSAP Kyma教程例子 edis-function

    包含一个 deployment 和两个 function:

    函数1:cache-order

    定义了三个依赖:

    • axios
    • redis
    • handy-redis

    环境变量

    这些环境变量的用法,在代码里使用 process.env 加上中括号引用。

    cache-order 函数的三大主要逻辑:

    (1)从 Kyma 传入的 event 结构里,获得 Commerce 创建订单的 ID.

    (2) 根据订单 ID,调用函数 getOrderDetails,获得订单明细。

    (3) 从订单明细里获得含税的价格,调用函数 cacheOrder,将价格存储到 Redis 里:

    getOrderDetails 的实现:

    async function getOrderDetails(orderCode) {
      const ordersUrl = `${COMM_GATEWAY_URL}/${process.env.SITE}/orders/${orderCode}`;
      console.log("Getting ordering details via: %s", ordersUrl, " for orderCode: ", orderCode);
      const response = await axios.get(ordersUrl);
      console.log(JSON.stringify(response.data, null, 2));
      return response.data;
    }
    

    代码里的 COMM_GATEWAY_URL 环境变量,在 Kyma 控制台里能够找到:

    cacheOrder 的实现,调用 redis client hmset 方法:

    resources

    定义了 CPU 和内存的 quota,以及源代码:

    这里的意思是,一旦应用 mp-commerce-mock 的 order.created 事件触发,会调用 cache-order 这个 function:

    函数2:get-order

    该函数的实现文件里,还定义了一个 APIRule:

    部署之后如图:

    定义了一个 gateway:
    gateway: kyma-gateway.kyma-system.svc.cluster.local

    从 Redis 里获取数据的源代码:

    const hredis = require("handy-redis");
    
    const client = hredis.createNodeRedisClient({
      port:  process.env["REDIS_PORT"],
      host: process.env["REDIS_HOST"],
      password: process.env["REDIS_PASSWORD"]
    });
    
    module.exports = { 
      main: async function (event, context) {
        try {   
          const orderCode = event.extensions.request.query.orderCode;
          let result = await processGetRequest(orderCode);
          return result ? result : {"error": "orderCode was not found"};
        }
        catch(err) {
          console.log("an error occurred...", err);
          event.extensions.response.status(500).json({"error": err});
        }
      }
    }
    
    async function processGetRequest(orderCode){    
      if(orderCode !== undefined){
        console.log("getting order from cache: ", orderCode);
        return client.hgetall(orderCode);
      }else{
        throw "No orderCode received!"
      }
    }
    
    

    关于如何测试这些 function,请参考 Jerry 这篇文章

    更多Jerry的原创文章,尽在:"汪子熙":

  • 相关阅读:
    nginx反向代理前后端分离项目(后端多台)
    部署http访问SVN模式出现403问题
    The server quit without updating PID file
    guns开源项目数据库切换为oracle
    window环境下修改postgrep密码
    mybatis中怎样使用having?
    PostgreSQL时间段查询
    Java实现产生一个int数组,长度为100,并向其中随机插入1-100,并且不能重复。
    Jenkins构建maven项目跳过测试用例的命令
    supervisord
  • 原文地址:https://www.cnblogs.com/sap-jerry/p/14889293.html
Copyright © 2011-2022 走看看