解析Redis MONITOR消息

Question

我正在尝试在 Redis 服务器和 MQTT 之间建立一座桥梁，以便在更新 Redis 数据库时，这些更新通过 MQTT 分派给客户端。

为此，客户端（只有一个，桥接器）连接到 Redis 数据库并开始监视它。

我的问题是解析命令，更具体地说是其中包含的参数，它是一个以空格分隔的字符串列表。

例如，当我将以下哈希存储在 Redis 中时

data = {

  "key-3-1-json": "value-1",

  "key-3-2-json": 'this "this is \'quoted\' text"',

}

print r18.hmset("test-hash", {

  "key-1": "value-1",

  "key-2": 'this "this is \'quoted\' text"',

  "key-3": json.dumps(data),

})

客户收到以下信息

1549578825.1 0 HMSET test-hash "key-3" "{\"key-3-1-json\": \"value-1\", \"key-3-2-json\": \"this \\\"this is 'quoted' text\\\"\"}" "key-2" "this \"this is 'quoted' text\"" "key-1" "value-1"

如您所见，我已经在解析时间戳、数据库 ID、命令和密钥，但最后一部分，我不知道如何从中创建字符串列表。

此消息随后将通过 MQTT 发送为

mqtt.publish("redis/mon/0/HMSET/test-hash", json.dumps(args))

args会在哪里

[

  "key-3",

  "{\"key-3-1-json\": \"value-1\", \"key-3-2-json\": \"this \\\"this is 'quoted' text\\\"\"}",

  "key-2",

  "this \"this is 'quoted' text\"",

  "key-1",

  "value-1"

]

这可能是最复杂的情况，因为在使用 wherer18.set代替r18.hmset.

我认为 Python 中必须有一些内置模块可以做到这一点，因为它就像解析命令行字符串一样。

Answer 1

该subprocess模块的文档说明subprocess.Popen()使用shlex.split()( shlex: Simple lexical analysis )调用shlex.split(args_str)有效地将参数字符串转换为所需的子字符串列表。