什么是 function ​

RedisShake 通过提供 function 功能，实现了的 ETL(提取-转换-加载) 中的 transform 能力。通过利用 function 可以实现类似功能：

• 更改数据所属的 db，比如将源端的 db 0 写入到目的端的 db 1。
• 对数据进行筛选，例如，只将 key 以 user: 开头的源数据写入到目标端。
• 改变 Key 的前缀，例如，将源端的 key prefix_old_key 写入到目标端的 key prefix_new_key。
• ...

要使用 function 功能，只需编写一份 lua 脚本。RedisShake 在从源端获取数据后，会将数据转换为 Redis 命令。然后，它会处理这些命令，从中解析出 KEYS、ARGV、SLOTS、GROUP 等信息，并将这些信息传递给 lua 脚本。lua 脚本会处理这些数据，并返回处理后的命令。最后，RedisShake 会将处理后的数据写入到目标端。

以下是一个具体的例子：

function = """
shake.log(DB)
if DB == 0
then
    return
end
shake.call(DB, ARGV)
"""

[sync_reader]
address = "127.0.0.1:6379"

[redis_writer]
address = "127.0.0.1:6380"

DB 是 RedisShake 提供的信息，表示当前数据所属的 db。shake.log 用于打印日志，shake.call 用于调用 Redis 命令。上述脚本的目的是丢弃源端 db 0 的数据，将其他 db 的数据写入到目标端。

除了 DB，还有其他信息如 KEYS、ARGV、SLOTS、GROUP 等，可供调用的函数有 shake.log 和 shake.call，具体请参考 function API。

关于更多的示例，可以参考 最佳实践。

function API ​

变量 ​

因为有些命令中含有多个 key，比如 mset 等命令。所以，KEYS、KEY_INDEXES、SLOTS 这三个变量都是数组类型。如果确认命令只有一个 key，可以直接使用 KEYS[1]、KEY_INDEXES[1]、SLOTS[1]。

函数 ​

• shake.call(DB, ARGV)：返回一个 Redis 命令，RedisShake 会将该命令写入目标端。
• shake.log(msg)：打印日志。