Установите файл загрузки с Api на Api - PullRequest
Новая
       36

Установите файл загрузки с Api на Api

0 голосов
/ 06 марта 2020

Я пытаюсь загрузить изображение из одного Asp net основного ядра в другой с помощью refit. 

await _repository.UploadImageAsync(userId,
    new StreamPart(file.OpenReadStream(), file.FileName, file.ContentType), extension);

API 

[Put("/image/{userId}")]
Task<Guid> UploadImageAsync(Guid userId, StreamPart stream, string extension);

Принимающий контроллер 

[HttpPut("image/{userId}")]
public async Task<IActionResult> UploadImageAsync([FromRoute] Guid userId, StreamPart stream, string extension)
{
    return await RunAsync(async () =>
    {
        var id = await _userImageManager.UploadImageAsync(userId, stream.Value, extension);

        return Ok(id);
    });
}

Как только я запускаю это, я получаю следующее исключение: 

Newtonsoft.Json.JsonSerializationException: Error getting value from 'ReadTimeout' on 'Microsoft.AspNetCore.Http.ReferenceReadStream'.
 ---> System.InvalidOperationException: Timeouts are not supported on this stream.
   at System.IO.Stream.get_ReadTimeout()
   at lambda_method(Closure , Object )
   at Newtonsoft.Json.Serialization.ExpressionValueProvider.GetValue(Object target)
   --- End of inner exception stack trace ---
   at Newtonsoft.Json.Serialization.ExpressionValueProvider.GetValue(Object target)
   at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.CalculatePropertyValues(JsonWriter writer, Object value, JsonContainerContract contract, JsonProperty member, JsonProperty property, JsonContract& memberContract, Object& memberValue)
   at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.SerializeObject(JsonWriter writer, Object value, JsonObjectContract contract, JsonProperty member, JsonContainerContract collectionContract, JsonProperty containerProperty)
   at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.SerializeValue(JsonWriter writer, Object value, JsonContract valueContract, JsonProperty member, JsonContainerContract containerContract, JsonProperty containerProperty)
   at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.SerializeObject(JsonWriter writer, Object value, JsonObjectContract contract, JsonProperty member, JsonContainerContract collectionContract, JsonProperty containerProperty)
   at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.SerializeValue(JsonWriter writer, Object value, JsonContract valueContract, JsonProperty member, JsonContainerContract containerContract, JsonProperty containerProperty)
   at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.Serialize(JsonWriter jsonWriter, Object value, Type objectType)
   at Newtonsoft.Json.JsonSerializer.SerializeInternal(JsonWriter jsonWriter, Object value, Type objectType)
   at Newtonsoft.Json.JsonSerializer.Serialize(JsonWriter jsonWriter, Object value, Type objectType)
   at Newtonsoft.Json.JsonConvert.SerializeObjectInternal(Object value, Type type, JsonSerializer jsonSerializer)
   at Newtonsoft.Json.JsonConvert.SerializeObject(Object value, Type type, JsonSerializerSettings settings)
   at Newtonsoft.Json.JsonConvert.SerializeObject(Object value, JsonSerializerSettings settings)
   at Refit.JsonContentSerializer.SerializeAsync[T](T item) in d:\a\1\s\Refit\JsonContentSerializer.cs:line 34
   at Refit.RequestBuilderImplementation.<>c__DisplayClass17_0.<<BuildRequestFactoryForMethod>b__0>d.MoveNext() in d:\a\1\s\Refit\RequestBuilderImplementation.cs:line 546
--- End of stack trace from previous location where exception was thrown ---
   at Refit.RequestBuilderImplementation.<>c__DisplayClass14_0`2.<<BuildCancellableTaskFuncForMethod>b__0>d.MoveNext() in d:\a\1\s\Refit\RequestBuilderImplementation.cs:line 243

Я попытался пойти по пути, описанному здесь , но безуспешно. Есть ли что-то, что я сделал не так?

РЕДАКТИРОВАТЬ

Основываясь на ответе @TomO, я отредактировал свой код, но я все равно получаю нулевое значение для stream:

Api 1 ( отправка части в Api 2): 

public async Task<Guid> UploadImageAsync(Guid userId, IFormFile file)
{
    ...
    var stream = file.OpenReadStream();

    var streamPart = new StreamPart(stream, file.FileName, file.ContentType);
    var response = await _repository.UploadImageAsync(userId,
                streamPart, extension);
    ...
}

Api 2 (Получатель): 

[HttpPost("image/{userId}")]
public async Task<IActionResult> UploadImageAsync([FromRoute] Guid userId, string description, IFormFile stream, string extension)
{
    ...
}

Refit Api: 

[Multipart]
[Post("/image/{userId}")]
Task<Guid> UploadImageAsync(Guid userId, [AliasAs("Description")] string description, [AliasAs("File")] StreamPart stream, string extension);

1 Ответ

1 голос
/ 23 апреля 2020

Я думаю, что документация (и решение, связанное с вопросом) дают хорошее руководство. Но вот что я получил для работы:

Получение конечной точки API: 

[HttpPost]
[Route("{*filePath:regex(^.*\\.[[^\\\\/]]+[[A-Za-z0-9]]$)}")]
public async Task<IActionResult> AddFile([FromRoute] AddFileRequest request,
                                         [FromForm] AddFileRequestDetails body,
                                         CancellationToken cancellationToken)

И соответствующий вызов клиента refit: 

[Multipart]
[Post("/{**filePath}")]
Task AddFile(string filePath, [AliasAs("Description")] string description, [AliasAs("File")] StreamPart filepart);

Важное Дело в том, что ВСЕ свойства-члены тела формы (не включая файл) должны быть украшены атрибутом «AliasAs».

Вызов на отправляющей стороне: 

            System.IO.Stream FileStream = request.File.OpenReadStream();
            StreamPart sp = new StreamPart(FileStream, request.FileName);

            try
            {
                await _filesClient.AddFile(request.FilePath, request.Description, sp);
            }
            catch (ApiException ae)
            {
                ...
                throw new Exception("Refit FileClient API Exception", ae);
            }

Надеюсь, это поможет следующему человеку ...

...