rust - 在 Rust 中反序列化 redis 的值 (FromRedisValue)
问题描述
我正在使用Rust 中的redis实现一个简单的任务队列,但我正在努力将 redis 的返回值反序列化为我的自定义类型。
我总共想到了 3 个方法:
- 使用serde-redis反序列化
- 手动实现
FromRedisValue
特征 - 使用serde-json序列化为字符串 > 作为字符串发送 > 然后从字符串反序列化
第三种方法有效,但感觉很不自然。我想弄清楚1或2,这两个我都失败了。
方法 1 - serde-redis
我有一个简单的任务定义:
#[derive(Debug, PartialEq, serde::Deserialize, serde::Serialize)]
pub struct Task {
pub id: u32,
pub desc: String,
}
我试图接收到一个工人:
use serde_redis::RedisDeserialize;
pub fn execute_task(conn: &mut Connection) {
let task: Task = redis::cmd("LPOP")
.arg("task_q")
.query::<Task>(conn)
.unwrap()
.deserialize()
.unwrap();
println!("... executing task {} ...", task.id);
}
但我收到以下错误:
error[E0277]: the trait bound `Task: FromRedisValue` is not satisfied
--> src/bin/worker.rs:38:10
|
38 | .query::<Task>(conn)
| ^^^^^ the trait `FromRedisValue` is not implemented for `Task`
error[E0599]: no method named `deserialize` found for struct `Task` in the current scope
--> src/bin/worker.rs:40:10
|
40 | .deserialize()
| ^^^^^^^^^^^ method not found in `Task`
很明显,我错误地集成了箱子,因为它不起作用。文档非常简短,作为初学者,源代码在我脑海中挥之不去——我会遗漏什么?
方法 2 - 手动实现 FromRedisValue
我天真的方法:
impl FromRedisValue for Task {
fn from_redis_value(v: &Value) -> RedisResult<Self> {
let t = Task {
id: v.id,
desc: v.desc,
};
RedisResult::Ok(t)
}
fn from_redis_values(items: &[Value]) -> RedisResult<Vec<Self>> {
let tasks = items
.into_iter()
.map(|v| Task {
id: v.id,
desc: v.desc,
})
.collect();
RedisResult::Ok(tasks)
}
}
我得到的错误:
error[E0609]: no field `id` on type `&Value`
--> src/redis_tut.rs:203:19
|
203 | id: v.id,
| ^^
error[E0609]: no field `desc` on type `&Value`
--> src/redis_tut.rs:204:21
|
204 | desc: v.desc,
| ^^^^
// ...the same for the vector implementation
很明显,redis 的值没有/不知道我想要的任务字段。这样做的正确方法是什么?
解决方案
Redis 没有定义结构化的序列化格式。它主要存储字符串和整数。所以你必须为你的结构选择或定义你的格式。
正如您所注意到的,一个流行的 JSON 是 JSON,但如果您只想(反)序列化简单的 (id, description) 对,它的可读性不强,也不方便。
在这种情况下,您可以定义自己的格式,例如 id 和中间有破折号的描述:
#[derive(Debug, PartialEq)]
pub struct Task {
pub id: u32,
pub desc: String,
}
// assume a task is defined as "<id>-<desc>"
impl FromRedisValue for Task {
fn from_redis_value(v: &Value) -> RedisResult<Self> {
let v: String = from_redis_value(v)?;
if let Some((id, desc)) = v.split_once('-') {
if let Ok(id) = id.parse() {
Ok(Task {
id,
desc: desc.to_string(),
})
} else {
Err((ErrorKind::TypeError, "bad first token").into())
}
} else {
Err((ErrorKind::TypeError, "missing dash").into())
}
}
}
推荐阅读
- php - 如何显示个人购物车价值?
- cassandra - Cassandra 进程被操作系统杀死
- python - 使用 for 循环将值附加到列表中的字典
- python - 如何使用 @contextlib.contextmanager 为函数实现 pytest?
- android - 高优先级创建的通知通道没有声音
- mongodb - Mongo - 索引是否使用全扫描?
- asp.net - C#中的文件上传
- java - 在 libgdx 中实现类似于“Candy Crush”的生命计数器
- mxnet - 如何使用 mxnet 符号做线性代数函数来编写自定义损失函数(例如在线三元组挖掘)?))
- python-3.x - OSError:[Errno 22] 无效参数:'E:\\project\\genres\\blues\x08lues.00000.au'