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

Я попытался загрузить 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?

Спасибо


c++ amazon-web-services amazon-s3 aws-sdk
person batuman    schedule 02.09.2016    source источник

Ответы (2)


arrow_upward
2
arrow_downward

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

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

Что касается проблемы с 0 байтами, в качестве обходного пути вы можете попробовать использовать объект std :: 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()));
person user3336690    schedule 30.09.2016

arrow_upward
2
arrow_downward

Что касается вашей первой проблемы: если другой ответ не сработал, попробуйте установить переменную 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 :: ate:

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);
person Yechiel Labunskiy    schedule 17.11.2016