企业🤖AI Agent构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
提供json数据格式的序列化和反序列化功能,包含encode和decode两个方法。 # **示例** t_user表,数据如下: ![](https://img.kancloud.cn/b7/ae/b7aea55df3a0d071d67a930b1f497314_589x141.png) Lua脚本: ``` -- t_user_json.lua local json = require("json") -- 加载json模块 local ops = require("redisOps") --加载redis操作模块 local row = ops.rawRow() --数据库当前变更的一行数据,table类型,key为列名称 local action = ops.rawAction() --当前数据库事件,包括:insert、updare、delete local id = row["ID"] --获取ID列的值 local key = "user_json_"..id -- 定义key if action == "insert" then -- 只监听insert事件 local password = row["PASSWORD"] --获取USER_NAME列的值 local createTime = row["CREATE_TIME"] --获取CREATE_TIME列的值 local result = {} -- 定义一个table result["id"] = id result["userName"] = userName result["password"] = password result["createTime"] = createTime result["source"] = "binlog" -- 数据来源 local val = json.encode(result) -- 将result转为json ops.SET(key,val) -- 对应Redis的SET命令,第一个参数为key(支持string类型),第二个参数为value end ``` 引入脚本: ``` rule: - schema: eseap table: t_user lua_file_path: lua/t_user_json.lua #lua脚本文件 ``` 同步到Redis的数据如下: ![](https://img.kancloud.cn/45/8f/458f147f0f00f3172cc1d37cad7a1e4d_483x223.jpg)