連接:https://developers.sap.com/tu...javascript
本地文件:C:\Code\referenceCode\SAP Kyma教程例子\redis-functionhtml
包含一個 deployment 和兩個 function:java
定義了三個依賴:ios
這些環境變量的用法,在代碼裏使用 process.env 加上中括號引用。redis
cache-order 函數的三大主要邏輯:json
(1)從 Kyma 傳入的 event 結構裏,得到 Commerce 建立訂單的 ID.axios
(2) 根據訂單 ID,調用函數 getOrderDetails,得到訂單明細。async
(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 方法:
定義了 CPU 和內存的 quota,以及源代碼:
這裏的意思是,一旦應用 mp-commerce-mock 的 order.created 事件觸發,會調用 cache-order 這個 function:
該函數的實現文件裏,還定義了一個 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的原創文章,盡在:"汪子熙":