MongoDB GridFS Rust驱动

此crate在mongodb的crate之上提供了Mongo GridFS的实现。此实现仅使用mongodb的async/await版本。

来自 https://github.com/mongodb/specifications/blob/master/source/gridfs/gridfs-spec.rst

GridFS是驱动程序用于存储和检索超出MongoDB的BSON文档大小限制（16 MiB）的BSON二进制数据（类型“\x05”）的一种约定。当这些数据（称为用户文件）写入系统时，GridFS将文件分割成多个块，这些块作为独立的文档存储在chunks集合中。要检索存储的文件，GridFS会定位并返回所有组成部分的块。内部，GridFS为每个存储的文件创建一个files集合文档。files集合文档包含有关存储文件的信息，并存储在files集合中。

示例

上传文档

use mongodb_gridfs::{options::GridFSBucketOptions, GridFSBucket};
let mut bucket = GridFSBucket::new(db.clone(), Some(GridFSBucketOptions::default()));
let id = bucket
    .upload_from_stream("test.txt", "stream your data here".as_bytes(), None)
    .await?;

下载文档

use futures::stream::StreamExt;
use mongodb_gridfs::{options::GridFSBucketOptions, GridFSBucket, GridFSError};

let bucket = GridFSBucket::new(db.clone(), Some(GridFSBucketOptions::default()));
let mut cursor = bucket.open_download_stream(id).await?;
let buffer = cursor.next().await.unwrap();

功能

以下功能传递给mongodb

• 默认
• async-std-runtime
• tokio-runtime

代码状态