Add ChainProvider for AWS S3 (#131)

delta-io · Mar 17, 2021 · e3d7038 · e3d7038
1 parent f1f3e07
commit e3d7038
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/rust/src/storage/s3.rs b/rust/src/storage/s3.rs
@@ -4,6 +4,7 @@ use std::{fmt, pin::Pin};
 use chrono::{DateTime, FixedOffset, Utc};
 use futures::Stream;
 use log::debug;
+use rusoto_core::credential::ChainProvider;
 use rusoto_core::{Region, RusotoError};
 use rusoto_s3::{
     GetObjectRequest, HeadObjectRequest, ListObjectsV2Request, PutObjectRequest, S3Client, S3,
@@ -119,7 +120,11 @@ pub struct S3StorageBackend {
 
 impl S3StorageBackend {
     pub fn new() -> Self {
-        let client = S3Client::new(Region::default());
+        let client = S3Client::new_with(
+            rusoto_core::HttpClient::new().expect("failed to create request dispatcher"),
+            ChainProvider::new(),
+            Region::default(),
+        );
         Self { client }
     }
 }