提供json數據格式的序列化和反序列化功能,包含encode和decode兩個方法。
# **示例**
t_user表,數據如下:

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的數據如下:

- 簡介
- 部署運行
- 高可用集群
- 同步數據到Redis
- Redis配置
- 基于規則同步
- 基于Lua腳本同步
- 同步數據到MongoDB
- MongoDB配置
- 基于規則同步
- 基于Lua腳本同步
- 同步數據到RocketMQ
- RocketMQ配置
- 基于規則同步
- 基于Lua腳本同步
- 同步數據到Kafka
- Kafka配置
- 基于規則同步
- 基于Lua腳本同步
- 同步數據到RabbitMQ
- RabbitMQ配置
- 基于規則同步
- 基于Lua腳本同步
- 同步數據到Elasticsearch
- Elasticsearch配置
- 基于規則同步
- 基于Lua腳本同步
- 全量數據導入
- Lua腳本
- 基礎模塊
- Json模塊
- HttpClient模塊
- DBClient模塊
- 監控
- 性能測試
- 常見問題
- 更新記錄開發計劃