- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
为了使用 reqwest 和 tokio 进行下载以及我正在使用下面的代码进行下载
pub async fn download_file(client: &Client, url: &str, path: &str) -> Result<(), String> {
// Reqwest setup
let res = client
.get(url)
.send()
.await
.or(Err(format!("Failed to GET from '{}'", &url)))?;
let total_size = res
.content_length()
.ok_or(format!("Failed to get content length from '{}'", &url))?;
// Indicatif setup
let pb = ProgressBar::new(total_size);
pb.set_style(ProgressStyle::default_bar()
.template("{msg}\n{spinner:.green} [{elapsed_precise}] [{wide_bar:.cyan/blue}] {bytes}/{total_bytes} ({bytes_per_sec}, {eta})")
.progress_chars("#>-"));
pb.set_message(format!("Downloading {}", url));
// download chunks
let mut file = File::create(path).or(Err(format!("Failed to create file '{}'", path)))?;
let mut downloaded: u64 = 0;
let mut stream = res.bytes_stream();
while let Some(item) = stream.next().await {
let chunk = item.or(Err(format!("Error while downloading file")))?;
file.write(&chunk)
.or(Err(format!("Error while writing to file")))?;
let new = min(downloaded + (chunk.len() as u64), total_size);
downloaded = new;
pb.set_position(new);
}
pb.finish_with_message(format!("Downloaded {} to {}", url, path));
return Ok(());
}
在 while 循环中,我可以设置进度并查看进度条,例如此处的示例 https://github.com/mitsuhiko/indicatif
现在我试图从上传中找到制作进度条,但找不到监控reqwest客户端的方法,下面的代码是我的上传功能
pub async fn upload_file(client: &Client, url: &str, path: &str) -> Result<(), String> {
let f = File::open(path).expect("Unable to open file");
let total_size = f.metadata().unwrap().len();
// Indicatif setup
let pb = ProgressBar::new(total_size);
pb.set_style(ProgressStyle::default_bar()
.template("{msg}\n{spinner:.green} [{elapsed_precise}] [{wide_bar:.cyan/blue}] {bytes}/{total_bytes} ({bytes_per_sec}, {eta})")
.progress_chars("#>-"));
pb.set_message(format!("Posting {}", url));
let file = tokio::fs::File::open(path).await.unwrap();
let stream = FramedRead::new(file, BytesCodec::new());
let res=client
.post(url)
.body(Body::wrap_stream(stream))
.send()
.await;
pb.finish_with_message(format!("Uploaded {} to {}", url, path));
return Ok(());
}
上传有效,但没有带百分比或任何指示器的进度条。应该有状态监视器,如下所示
.post(url)
.body(Body::wrap_stream(stream))
.send()
.monitorStatus(|stat|{
pb.set_position(stat);
}).....
你可以在这里看到工作代码https://github.com/ozkanpakdil/rust-examples/blob/5f4965f2b086d07c8294352182639dc75232bb30/download_upload/src/download_file.rs#L43只需取消注释这些测试并运行 cargo test
我的问题是,如何监控 reqwest 客户端的上传并从中制作进度条?
最佳答案
您可以创建一个 async_stream
并生成要上传的输入 block :
let file = tokio::fs::File::open(&input).await.unwrap();
let total_size = file.metadata().await.unwrap().len();
let input_ = input.to_string();
let output_ = output.to_string();
let mut reader_stream = ReaderStream::new(file);
let mut uploaded = HTTPSHandler::get_already_uploaded(output).await;
bar.set_length(total_size);
let async_stream = async_stream::stream! {
while let Some(chunk) = reader_stream.next().await {
if let Ok(chunk) = &chunk {
let new = min(uploaded + (chunk.len() as u64), total_size);
uploaded = new;
bar.set_position(new);
if(uploaded >= total_size){
bar.finish_upload(&input_, &output_);
}
}
yield chunk;
}
};
然后,在构建 Body
时将流包装起来:
let _ = reqwest::Client::new()
.put(output)
.header("content-type", "application/octet-stream")
.header("Range", "bytes=".to_owned() + &uploaded.to_string() + "-")
.header(
reqwest::header::USER_AGENT,
reqwest::header::HeaderValue::from_static(CLIENT_ID),
)
.body(reqwest::Body::wrap_stream(async_stream))
.send()
.await
.unwrap();
顺便说一下,看看 aim 的实现,我在那里遇到过类似的问题!
关于rust - 如何监控reqwest客户端上传进度,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/70252995/
我正在尝试编写一个与 Todoist 的 REST API 通信的库。这个想法是库公开了一个 TodoistAPI 结构,其中包含一个 reqwest::Client 和一个 base_url。有一个
我是rust的新手,正在尝试获取请求响应主体,我当前的代码是: let client = reqwest::Client::new(); let response_text = client.get(
我正在尝试运行基本的 reqwest example : extern crate reqwest; extern crate tokio; #[tokio::main] async fn main(
我正在尝试在我正在编写的Rust程序中使用this Python script(取自here)的某些部分。如何构造具有相同内容的reqwest请求? def login(login_url, user
我正在使用 reqwest (版本 0.10.4)用于 Rust 应用程序中的 HTTP 调用,但找不到任何示例说明如何处理可能返回多个可能响应主体的 API 调用,主要用于错误处理。 例如,API
我发现的只是 ClientBuilder 有一个选项可以设置每台主机的最大空闲连接数,但这似乎并没有对可用连接数提供总体限制。 最佳答案 看起来 Reqwest 工作在 Tokio 之上。您可以 co
我很困惑为什么我没有从以下使用 reqwest 的函数中获取任何内容: fn try_get() { let wc = reqwest::Client::new(); wc
当我运行以下代码时: use exitfailure::ExitFailure; use reqwest::Url; use serde_derive::{Deserialize, Serialize
我对 Rust 很陌生,我似乎无法找到解决这个问题的方法。我正在尝试以 json 形式获取 get 请求的响应。 #[macro_use] extern crate serde; extern cra
通过 reqwest 的请求需要长轮询响应,因此我创建了一个字节流并尝试将每个块反序列化为 JSON。我立即意识到这是错误的,因为每个块都可能不完整,因此反序列化可能会失败;尽管一些块被反序列化为 J
我一直在研究Rust,并遇到了以下代码: fn request(&url) -> Result> { let mut res = reqwest::get(&url)?; let mut bo
我有一个包含以下日期的字符串 2015-07-05T11:02:25+00:00。 我使用下面的代码来解析它(使用 chrono crate) let pub_date = str::repl
我正在尝试使用 Reqwest 的代理功能将 user:pass basic auth 与 URL 的其余部分一起传递到代理功能中。显然,这个 crate 的基本身份验证工作方式不能以这种方式传递给代
我试图让一个基本的 reqwest http-request 像这样进行 extern crate reqwest; extern crate url; use url::Url; fn main()
我需要下载一个 60MB 的 ZIP 文件并提取其中的唯一文件。我想下载它并使用流提取它。我如何使用 Rust 实现这一点? fn main () { let mut res = reqwes
这个问题在这里已经有了答案: How do you enable a Rust "crate feature"? (1 个回答) 关闭 3 年前。 我正在尝试使用 reqwest 0.10.0-al
我需要使用 Reqwest 库向带有 cookie 的网站发出 GET 请求。我想出了如何发送 GET 请求: let response = reqwest::get("http://example.
在过去的几天里,我一直在搞乱 HTTP,在 Rust 中构建了一个简单的 CL 下载管理器,使用 reqwest crate 来处理 HTTP 内容。我对协议(protocol)的工作原理有了基本的了
我正在使用以下系统来处理 AJAX 上传:https://github.com/ded/reqwest 虽然它适用于我迄今为止尝试过的所有内容 - 我现在需要上传文件(当输入更改时)。你怎样做呢?到目
在我的 actix-web 服务器中,我尝试使用 reqwest 调用外部服务器,然后将响应返回给用户。 use actix_web::{web, App, HttpResponse, HttpSer
我是一名优秀的程序员,十分优秀!