Загрузка avi-файла в AWS S3 с помощью aws-cpp-sdk

Question

Я попытался загрузить файл avi в хранилище aws s3, используя следующий код.

#include <aws/core/utils/HashingUtils.h> 
#include <aws/core/Aws.h> 
#include <aws/s3/S3Client.h> 
#include <aws/s3/model/PutObjectRequest.h> 
#include <aws/s3/model/CreateBucketRequest.h> 
#include <iostream> 
#include <fstream> 

using namespace Aws::S3::Model; 
using namespace std; 
using namespace Aws::Utils; 

static const char* KEY = "test.avi";//"s3_cpp_sample_key"; 
static const char* BUCKET = "testnmn";//"s3-cpp-sample-bucket"; 

int main() 
{ 

    Aws::SDKOptions options; 
    Aws::InitAPI(options); 


    const Aws::String key_name = KEY; 
    const Aws::String dir_name = "/home/Softwares/Projects/S3upload/build"; 

    Aws::S3::S3Client s3_client; 
    Aws::S3::Model::CreateBucketRequest bucket_request; 
    bucket_request.WithBucket("testavinmn"); 
    auto create_bucket_outcome1 = s3_client.CreateBucket(bucket_request); 
    if(create_bucket_outcome1.IsSuccess()) { 
     std::cout << "Done!" << std::endl; 
    } 
    else { 
     std::cout << "CreateBucket error: " << 
      create_bucket_outcome1.GetError().GetExceptionName() << std::endl << 
      create_bucket_outcome1.GetError().GetMessage() << std::endl; 
    } 

    Aws::S3::Model::PutObjectRequest object_request; 
    object_request.WithBucket("testavinmn").WithKey(key_name); 

    auto input_data = Aws::MakeShared<Aws::FStream>(key_name.c_str(), dir_name.c_str(), std::ios_base::in); 
    object_request.SetBody(input_data); 
    object_request.SetContentType("avi"); 
    object_request.SetContentLength(static_cast<long>(object_request.GetBody()->tellg())); 
    object_request.SetContentMD5(HashingUtils::Base64Encode(HashingUtils::CalculateMD5(*object_request.GetBody()))); 
    auto put_object_outcome = s3_client.PutObject(object_request); 

    if(put_object_outcome.IsSuccess()) { 
     std::cout << "Done!" << std::endl; 
    } 
    else { 
     std::cout << "PutObject error: " << 
      put_object_outcome.GetError().GetExceptionName() << " " << 
      put_object_outcome.GetError().GetMessage() << std::endl; 
    } 

    Aws::ShutdownAPI(options); 

    return 0; 
} 

В коде есть несколько вопросов.

(1) Первым из них является создание ковша и помещение объекта во вновь созданный ковш. Он не может поместить объект в существующее ведро. Причина может быть из-за региона существующего ведра. Как я могу выбрать область существующего ведра, чтобы объект мог быть помещен в существующее ведро? Любой C++ api для этого?

(2) Вторая проблема заключается в том, что загруженный объект имеет 0 байтов данных. Для этого проблемой может быть проблема input_data, чтобы открыть и прочитать файл для загрузки. Как открыть и прочитать файл в aws-cpp-sdk?

Благодаря

Answer 1

Для настройки вашего региона, вы можете использовать ClientConfiguration-структуру и передать объект при создании клиента S3, как:

Aws::Client::ClientConfiguration myConf; 
myConf.region = Aws::Region::US_WEST_2; 
Aws::S3::S3Client s3_client(myConf); 

Что касается вопроса 0 байт, в качестве обходного пути, вы можете попробуйте использовать объект станд :: fstream и установить длину содержимого:

auto input_data = std::make_shared<std::fstream> (key_name.c_str(),std::ios_base::in); 
input_data->seekp(0, std::ios_base::end); 
object_request.SetBody(input_data); 
object_request.SetContentLength(static_cast<long>(object_request.GetBody()->tellp())); 

Answer 2

Что касается вашего первого вопроса: Если другой ответ не работает, т чень установки переменной endpointOverride содержать полный путь к ведру:

Aws::Client::ClientConfiguration cc; 
cc.region = Aws::Region::EU_WEST_1; 
cc.endpointOverride = "s3-eu-west-1.amazonaws.com/<bucket_name>"; 
Aws::S3::S3Client s3_client(cc); 

Что касается вашего второго вопроса, то вы можете использовать обычный C++ fstream, и открыть его с помощью ios_base :: поел флаг:

std::shared_ptr<std::fstream> input_data = 
    std::make_shared<std::fstream>(full_path.c_str(), 
      std::ios_base::in | std::ios_base::ate); 
object_request.SetContentLength(input_data->tellg()); 
object_request.SetBody(input_data);