Загрузка файла AWS S3 .NET SDK (.NET Core) Невозможно записать данные в транспортное соединение - PullRequest
Новая
       18

Загрузка файла AWS S3 .NET SDK (.NET Core) Невозможно записать данные в транспортное соединение

0 голосов
/ 28 марта 2019

Я пишу функцию для загрузки нескольких файлов в AWS S3. Даже с одним файлом, закомментированный код, использующий TransferUtilityUploadRequest ниже, завершается ошибкой:

System.IO.IOException: невозможно записать данные в транспорт соединение: существующее соединение было принудительно закрыто удаленным хозяйничать.

Код без комментариев работает (но я не могу установить разрешения ACL). Посмотрев несколько примеров в интернете, я не уверен, что делаю не так? RequestFormLimits здесь не является проблемой, код завершается ошибкой в ​​момент, когда он пытается загрузить на S3. 

    [HttpPost("test/raw-file-upload-s3")]
    [RequestFormLimits(MultipartBodyLengthLimit = 1073741824)]
    [RequestSizeLimit(1073741824)]
    public async Task<ActionResult<object>> UploadFiles3(IList<IFormFile> files)
    {
        var regionEndpoint = RegionEndpoint.GetBySystemName(_awsS3RegionEndpoint);

        var uploadedFileNames = new List<string>();

        using (var awsS3Client = new AmazonS3Client(new BasicAWSCredentials(_awsAccessKeyId, _awsSecretKey), regionEndpoint))
        {
            using (var fileTransferUtility = new TransferUtility(awsS3Client))
            {
                var dateBasedDirectoryName = GetDateBasedDirectoryName();

                string contentDirectory = $@"example/";

                var tasks = new Task[files.Count];

                var streams = new Stream[files.Count];

                for (int i = 0; i < files.Count; i++)
                {
                    string fileName = $"{Guid.NewGuid()}_{files[i].FileName}";

                    string key = $"{contentDirectory}{fileName}";

                    streams[i] = files[i].OpenReadStream();

                    tasks[i] = fileTransferUtility.UploadAsync(streams[i], _awsS3AssetsBucket, key);

                    // var fileTransferUtilityRequest = new TransferUtilityUploadRequest
                    // {
                    //     BucketName = _awsS3AssetsBucket,
                    //     Key = key,
                    //     CannedACL = S3CannedACL.PublicRead,
                    //     InputStream = streams[i]
                    // };

                    // tasks[i] = fileTransferUtility.UploadAsync(fileTransferUtilityRequest);
                }

                await Task.WhenAll(tasks).ConfigureAwait(false);

                for (int i = 0; i < files.Count; i++)
                {
                    streams[i].Close();
                }
            }
        }

        return new
        {
            uploadedFiles = uploadedFileNames
        };
    }

1 Ответ

0 голосов
/ 28 марта 2019

Можете ли вы попробовать ниже 

// Set Canned ACL (PublicRead) for an existing item
client.PutACL(new PutACLRequest
{
    BucketName = _awsS3AssetsBucket,
    Key = key,
    CannedACL = S3CannedACL.PublicRead
});

До этой строки 

tasks[i] = fileTransferUtility.UploadAsync(streams[i], _awsS3AssetsBucket, key);
...