С c ++ S3 SDK ListObjecsV2 с Minio не возвращает результатов - PullRequest
0 голосов
/ 07 мая 2020

Ниже приведен код, который помещает объект в корзину s3, извлекает его обратно, а затем пытается составить список для корзины. Команды put и get работают нормально, но перечисление ведра не возвращает ключей (но не ошибки). Я могу перечислить сегмент, используя golang api и те же параметры (имя сегмента и пустой префикс). Почему он не отображает ведро?

Aws::SDKOptions opts;

opts.loggingOptions.logLevel = Aws::Utils::Logging::LogLevel::Debug;
Aws::InitAPI(opts);

Aws::Auth::AWSCredentials credentials;
Aws::Client::ClientConfiguration config;
Aws::S3::S3Client client;

credentials.SetAWSAccessKeyId("accesskey");
credentials.SetAWSSecretKey("secretkey");
config.endpointOverride = "localhost:5553";
config.scheme = Aws::Http::Scheme::HTTP;
config.verifySSL = false;
client = Aws::S3::S3Client(credentials, config);

const char* bucket = "buck";
const char* key = "buck/key";

// Putting works!
//
Aws::S3::Model::PutObjectRequest pRequest;
pRequest.SetBucket(bucket);
pRequest.SetKey(key);

auto stream = Aws::MakeShared<Aws::StringStream>("tag", "some data");
pRequest.SetBody(stream);

Aws::S3::Model::PutObjectOutcome pOutcome = client.PutObject(pRequest);

if (!pOutcome.IsSuccess())
{
    printf("put failed S3 because %s: %s\n",
           pOutcome.GetError().GetExceptionName().c_str(),
           pOutcome.GetError().GetMessage().c_str());
    printf("\n\n\n\n");
    assert(false);
}

printf("object put\n");

// Getting works!
//
Aws::S3::Model::GetObjectRequest gRequest;
gRequest.SetBucket(bucket);
gRequest.SetKey(key);

Aws::S3::Model::GetObjectOutcome gOutcome = client.GetObject(gRequest);

if (!gOutcome.IsSuccess())
{
    printf("get failed S3 because %s: %s\n",
           gOutcome.GetError().GetExceptionName().c_str(),
           gOutcome.GetError().GetMessage().c_str());
    printf("\n\n\n\n");
    assert(false);
}

printf("object got\n");

char buf[1000];
memset(buf, 0, 1000);
gOutcome.GetResult().GetBody().read(buf, 1000);

printf("object say '%s'\n", buf);

// THIS IS THE PROBLEMATIC CODE
//
Aws::S3::Model::ListObjectsV2Request request;
request.SetBucket(bucket);                
request.SetPrefix("");
request.SetMaxKeys(1000);

Aws::S3::Model::ListObjectsV2Outcome outcome = client.ListObjectsV2(request);

if (!outcome.IsSuccess())
{
    printf("Failed to list files from S3 because %s: %s\n",
           outcome.GetError().GetExceptionName().c_str(),
           outcome.GetError().GetMessage().c_str());
    printf("\n\n\n\n");
    assert(false);
}

printf("num keys returned %d\n", outcome.GetResult().GetKeyCount());

for (const Aws::S3::Model::Object& obj : outcome.GetResult().GetContents())
{
    printf("Callback %s", obj.GetKey().c_str());
}

Aws::Utils::Logging::ShutdownAWSLogging();

exit(0);

Я использую minio в качестве хранилища объектов, но с amazon s3 он отлично работает

1 Ответ

0 голосов
/ 07 мая 2020

глядя на разницу в HTTP-запросах и читая код, похоже, что вам нужно установить m_useVirtualAddressing в значение true в S3Client.

Хорошо ... кто знал.

Мой клиент говорит

   client = Aws::S3::S3Client(credentials, config, Aws::Client::AWSAuthV4Signer::PayloadSigningPolicy::Never, false);
...