Rust使用hyper/azure SDK返回流时BlobClient生命周期错误问题

错误原因 #

blob.get()返回的GetBlobBuilder是对局部变量blob的借用，调用.stream(128)生成的流生命周期会和blob绑定。而hyper::Body::wrap_stream要求传入的流满足'static生命周期（不能借用任何函数局部变量），blob在handle函数结束时就会被销毁，导致流出现悬垂借用，因此编译报错。

解决方案 #

方案1：小文件场景（实现最简单）

先全量读取Blob内容到内存，再构造owned的流返回，无需处理复杂生命周期：

async fn handle(_req: Request<Body>) -> Result<Response<Body>, azure_core::error::Error> {
    let http_client = new_http_client();
    let storage_account_client = StorageAccountClient::new_access_key(http_client.clone(), "account", "key");
    let storage_client = storage_account_client.as_storage_client();
    let blob = storage_client.as_container_client("container").as_blob_client("blob");

    // 全量读取Blob内容
    let mut stream = blob.get().stream(128);
    let mut full_data = Vec::new();
    while let Some(chunk) = stream.try_next().await? {
        full_data.extend_from_slice(&chunk.data);
    }

    // 构造静态生命周期的流返回
    let resp_stream = futures::stream::once(async move { Ok::<_, std::io::Error>(full_data) });
    Ok(Response::new(Body::wrap_stream(resp_stream)))
}

该方案缺点是大文件会占用较多内存，适合小体积Blob场景。

方案2：大文件流式场景

通过futures::stream::unfold让流持有BlobClient的所有权，避免借用局部变量，实现真正的流式传输：

async fn handle(_req: Request<Body>) -> Result<Response<Body>, azure_core::error::Error> {
    let http_client = new_http_client();
    let storage_account_client = StorageAccountClient::new_access_key(http_client.clone(), "account", "key");
    let storage_client = storage_account_client.as_storage_client();
    let blob = storage_client.as_container_client("container").as_blob_client("blob");

    // unfold的状态持有BlobClient和流，保证整个流没有外部借用
    let resp_stream = futures::stream::unfold((blob, None), |(blob, stream_opt)| async move {
        let mut stream_opt = stream_opt;
        if stream_opt.is_none() {
            stream_opt = Some(Box::pin(blob.get().stream(128)));
        }
        let stream = stream_opt.as_mut().unwrap();
        match stream.try_next().await {
            Ok(Some(chunk)) => Some((Ok::<_, azure_core::error::Error>(chunk.data), (blob, stream_opt))),
            _ => None,
        }
    }).boxed();

    Ok(Response::new(Body::wrap_stream(resp_stream)))
}

该方案无需全量加载Blob到内存，适合大文件传输场景。

注意事项 #

你原代码中handle函数的返回错误类型是Infallible（无错误），但Blob读取过程中可能出现网络、IO、权限等错误，需要调整返回错误类型为兼容的错误枚举，避免编译错误。

内容的提问来源于stack exchange，提问作者tyhi