共计 1697 个字符,预计需要花费 5 分钟才能阅读完成。
链接:https://developers.sap.com/tu…
本地文件:C:\Code\referenceCode\SAP Kyma 教程例子 \redis-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 的原创文章,尽在:” 汪子熙 ”:
正文完