我正在尝试创建一个接受一些参数作为JSON的Web服务器,并将它们转换为一个结构,然后我将其存储在我的应用程序中的其他位置。
我在名为status.rs的文件中有这个数据结构:
use serde::{Serialize, Deserialize};
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Status {
pub id: String,
pub rssi: Option<i8>,
pub carrier: Option<String>,
pub timestamp: u64,
}
然后我在Hyper中的服务中使用以下代码来尝试解析请求的主体并将其转换为我的结构。唯一的区别是我想根据服务器上的时间戳添加时间戳字段,而不是在客户端上:
let timestamp: u64 = SystemTime::now()
.duration_since(UNIX_EPOCH)
.expect("PANIC! Time is running backwards!")
.as_secs();
Box::new(req.into_body().concat2().map(|body| {
let body_bytes = body.into_bytes();
let body_str = match str::from_utf8(&body_bytes) {
Ok(v) => v,
Err(e) => {
// TODO: this is shitty error handling
panic!("Unable to read UTF8 input: {}", e);
}
};
let input_data: Value = serde_json::from_str(body_str).unwrap();
let data = Status {
id: input_data.get("id").unwrap(),
timestamp: timestamp,
rssi: input_data.get("rssi"),
carrier: input_data.get("carrier"),
};
update(data);
}));
更新功能只是将其插入数据存储结构中。
我尝试过几种不同的方式,但这种方式给我的问题是这些字段中的每一个都是Option<&Value>
类型(我认为)。
希望我试图实现的结果足够清楚,我只是不知道如何获取请求体,解析JSON,添加时间戳,并将其打包在一个结构中,然后存储在我的数据库中。
我该怎么办呢?
你试图将body转换为字节切片,然后转换为字符串,然后转换为serde_json::Value
,然后转换为Status
。相当多的不必要的中间步骤,对吧?只需阅读文档:
let body = req.into_body().concat2().wait().unwrap().into_bytes();
let s: Status = serde_json::from_slice(&body).unwrap();