38 releases (19 breaking)

0.48.2 Nov 7, 2024
0.48.0 Sep 18, 2024
0.45.0 Jul 29, 2024
0.43.0 Mar 2, 2024
0.30.5 Mar 31, 2023

#5 in #opendal

Download history 1824/week @ 2024-08-14 1055/week @ 2024-08-21 1159/week @ 2024-08-28 1452/week @ 2024-09-04 1078/week @ 2024-09-11 1466/week @ 2024-09-18 991/week @ 2024-09-25 340/week @ 2024-10-02 1179/week @ 2024-10-09 1154/week @ 2024-10-16 1545/week @ 2024-10-23 1467/week @ 2024-10-30 1299/week @ 2024-11-06 1288/week @ 2024-11-13 1760/week @ 2024-11-20 812/week @ 2024-11-27

5,388 downloads per month

Apache-2.0

3MB
62K SLoC

Apache OpenDAL™ object_store integration

Build Status Latest Version Crate Downloads chat

object_store_opendal is an object_store implementation using opendal.

This crate can help you to access 30 more storage services with the same object_store API.

Examples

Add the following dependencies to your Cargo.toml with correct version:

[dependencies]
object_store = "0.11.0"
object_store_opendal = "0.47.0"
opendal = { version = "0.49.0", features = ["services-s3"] }

Build OpendalStore via opendal::Operator:

use std::sync::Arc;

use bytes::Bytes;
use object_store::path::Path;
use object_store::ObjectStore;
use object_store_opendal::OpendalStore;
use opendal::services::S3;
use opendal::{Builder, Operator};

#[tokio::main]
async fn main() {
    let builder = S3::from_map(
        vec![
            ("access_key".to_string(), "my_access_key".to_string()),
            ("secret_key".to_string(), "my_secret_key".to_string()),
            ("endpoint".to_string(), "my_endpoint".to_string()),
            ("region".to_string(), "my_region".to_string()),
        ]
        .into_iter()
        .collect(),
    ).unwrap();

    // Create a new operator
    let operator = Operator::new(builder).unwrap().finish();

    // Create a new object store
    let object_store = Arc::new(OpendalStore::new(operator));

    let path = Path::from("data/nested/test.txt");
    let bytes = Bytes::from_static(b"hello, world! I am nested.");

    object_store.put(&path, bytes.clone().into()).await.unwrap();

    let content = object_store
        .get(&path)
        .await
        .unwrap()
        .bytes()
        .await
        .unwrap();

    assert_eq!(content, bytes);
}

Branding

The first and most prominent mentions must use the full form: Apache OpenDAL™ of the name for any individual usage (webpage, handout, slides, etc.) Depending on the context and writing style, you should use the full form of the name sufficiently often to ensure that readers clearly understand the association of both the OpenDAL project and the OpenDAL software product to the ASF as the parent organization.

For more details, see the Apache Product Name Usage Guide.

License and Trademarks

Licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0

Apache OpenDAL, OpenDAL, and Apache are either registered trademarks or trademarks of the Apache Software Foundation.

Dependencies

~12–23MB
~329K SLoC