函数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的原创文章，尽在："汪子熙":