Início / coding / Perguntas / 79583717
Accepted
Francesco Cina
Asked: 2025-04-21 04:18:17 +0800 CST

Como criar um Axum Body a partir de um leitor OpenDAL?

  • 772

Preciso construir um Axum Body a partir de um leitor OpenDAL, mas não consigo encontrar nenhuma maneira de fazer isso. Alguém sabe como fazer? Código de exemplo:

use axum::body::Body;
use opendal::{services, Operator};
use http_body_util::StreamBody;

async fn to_body() -> Body {
    let op = Operator::new(services::Fs::default().root("./")).unwrap().finish();
    let reader = op.reader("../Cargo.toml").await.unwrap();
    let stream = reader.into_stream(..).await.unwrap();

    // stream implements futures_core::stream::Stream so I expected this to work, but it doesn't:
    // let body = Body::from_stream(stream);

    // I can build a StreamBody but then I fail to create a Body from it
    let stream_body = StreamBody::new(stream).into();

    // Now I am not able to convert the stream_body to a Body
}
rust

1 respostas

  1. Best Answer

    Use .into_bytes_stream()em vez disso:

    let stream = reader.into_bytes_stream(..).await.unwrap();

    Então, o fluxo resultante pode ser passado diretamente para Body::from_stream:

    Body::from_stream(stream)

    Isso funciona porque Stream<Item = Result<Bytes, _>>é uma maneira semi-padronizada de representar um fluxo de bytes. O único problema potencial pode ser a conversão de erros, mas o fluxo OpenDAL usa std::io::Erroro tipo de erro que já é diretamente convertível para Box<dyn Error>o que o axum usa.

    • 2

relate perguntas