From e3d7038b48dde9a4e59f39f0e28ecd403dfd2eec Mon Sep 17 00:00:00 2001 From: fvaleye Date: Wed, 17 Mar 2021 19:16:44 +0100 Subject: [PATCH] Add ChainProvider for AWS S3 (#131) --- rust/src/storage/s3.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/rust/src/storage/s3.rs b/rust/src/storage/s3.rs index 35429ee9d5..5df0d10294 100644 --- 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 } } }