如何在Rust后端中使用MinIO？遇依赖报错求解决方案

你遇到的minio crate未声明问题，是因为官方的minio-rs库目前暂不可用/维护停滞，不过Rust完全可以使用MinIO——因为MinIO兼容Amazon S3 API，所有支持S3的Rust客户端库都能直接对接MinIO，下面是具体的实现方案和教程：

推荐方案：使用AWS SDK for Rust（aws-sdk-s3） #

AWS官方的Rust SDK对S3 API支持完善，且维护活跃，完全兼容MinIO，是当前的首选方案。

步骤1：添加依赖到Cargo.toml #

在项目的Cargo.toml中加入以下依赖：

[dependencies]
aws-sdk-s3 = "0.31.0"
aws-config = "0.55.0"
tokio = { version = "1.0", features = ["full"] }

步骤2：编写MinIO客户端代码 #

以下是一个完整的示例，包含客户端初始化、列出存储桶的功能：

use aws_sdk_s3::{Client, Config, Credentials, Endpoint};

#[tokio::main]
async fn main() -> Result<(), aws_sdk_s3::Error> {
    // 替换为你的MinIO实例配置
    let minio_endpoint = "http://localhost:9000";
    let minio_access_key = "你的MinIO访问密钥";
    let minio_secret_key = "你的MinIO秘密密钥";
    let region = "us-east-1"; // MinIO对区域要求宽松，任意填写即可

    // 创建MinIO凭证
    let credentials = Credentials::new(
        minio_access_key,
        minio_secret_key,
        None,
        None,
        "custom",
    );

    // 配置MinIO服务端点
    let endpoint = Endpoint::immutable(minio_endpoint)?;

    // 构建客户端配置
    let config = Config::builder()
        .endpoint(endpoint)
        .credentials_provider(credentials)
        .region(region)
        .build();

    // 初始化兼容MinIO的S3客户端
    let client = Client::from_conf(config);

    // 测试：列出所有存储桶
    let resp = client.list_buckets().send().await?;
    println!("当前存储桶列表：");
    for bucket in resp.buckets().unwrap_or_default() {
        println!(" - {}", bucket.name().unwrap_or_default());
    }

    Ok(())
}

常用操作示例 #

• 创建存储桶：

client.create_bucket()
    .bucket("my-new-bucket")
    .send()
    .await?;

• 上传文件：

use std::fs::File;
use std::io::Read;

let mut file = File::open("local-file.txt")?;
let mut contents = Vec::new();
file.read_to_end(&mut contents)?;

client.put_object()
    .bucket("my-bucket")
    .key("remote-file.txt")
    .body(contents.into())
    .send()
    .await?;

备选方案：使用rusoto_s3 #

若你偏好更轻量的库，rusoto_s3也是一个可选方案（注意：rusoto目前维护频率较低）：

添加依赖 #

[dependencies]
rusoto_s3 = "0.48.0"
rusoto_core = "0.48.0"
tokio = { version = "1.0", features = ["full"] }

客户端初始化示例 #

use rusoto_core::{HttpClient, Region};
use rusoto_s3::{S3Client, S3};

#[tokio::main]
async fn main() {
    let region = Region::Custom {
        name: "us-east-1".to_string(),
        endpoint: "http://localhost:9000".to_string(),
    };

    let client = S3Client::new_with(
        HttpClient::new().unwrap(),
        rusoto_core::credential::StaticProvider::new(
            "你的MinIO访问密钥".to_string(),
            "你的MinIO秘密密钥".to_string(),
            None,
            None,
        ),
        region,
    );

    // 列出存储桶
    let resp = client.list_buckets().await.unwrap();
    println!("存储桶列表：");
    for bucket in resp.buckets.unwrap_or_default() {
        println!(" - {}", bucket.name.unwrap_or_default());
    }
}

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