Использование оберточного потока для отслеживания прогресса скачивания в Delphi с библиотекой Embarcadero's AmazonAPI

Delphi , Программа и Интерфейс , Процессы и Сервисы

Вопрос пользователя касается возможности отслеживания прогресса загрузки объектов из сервиса Amazon S3 с использованием библиотеки Embarcadero's AmazonAPI. В частности, интересует, есть ли в классе TAmazonStorageService какие-либо рутины для мониторинга этого процесса.

Ответ на вопрос

В текущей версии библиотеки Embarcadero's AmazonAPI для Delphi напрямую возможность отслеживания прогресса скачивания объектов из S3 не предусмотрена. Однако разработчики могут использовать альтернативный подход, реализовав оберточный поток, который будет уведомлять о прогрессе записи в него. Такой подход можно реализовать, создав класс TProgressStream, который будет перехватывать операции записи и вызывать обработчик прогресса.

Пример реализации

Допустим, у нас есть процедура OnProgress, которая обновляет прогресс-бар при получении уведомления о прогрессе:

procedure TForm1.OnProgress(const ACount: Int64);
begin
  ProgressBar1.Value := ProgressBar1.Value + ACount;
  Application.ProcessMessages;
end;

Далее, мы можем определить процедуру DownloadFile, которая будет скачивать файл из S3, используя наш оберточный поток:

procedure TForm1.DownloadFile(const ABucketName, AFileName: string);
var
  ResponseInfo: TCloudResponseInfo;
  StorageService: TAmazonStorageService;
  ObjectName: string;
  FileStream: TFileStream;
  ProgressStream: TProgressStream;
  MetaData, Properties: TStrings;
  ContentLength: Int64;
begin
  StorageService := TAmazonStorageService.Create(AmazonConnectionInfo1);
  ResponseInfo := TCloudResponseInfo.Create;
  try
    ObjectName := ExtractFileName(AFileName);
    if StorageService.GetObjectProperties(ABucketName, ObjectName, Properties, MetaData) then
    begin
      try
        ContentLength := StrToInt(Properties.Values['Content-Length']);
      finally
        MetaData.Free;
        Properties.Free;
      end;
      FileStream := TFileStream.Create(AFileName, fmCreate or fmOpenWrite);
      ProgressStream := TProgressStream.Create(FileStream);
      ProgressStream.OnProgress := OnProgress;
      ProgressBar1.Max := ContentLength;
      ProgressBar1.Value := 0;
      try
        StorageService.GetObject(ABucketName, ObjectName, ProgressStream);
      finally
        ProgressStream.Free;
        FileStream.Free;
      end;
    end;
  finally
    StorageService.Free;
    ResponseInfo.Free;
  end;
end;

Для реализации TProgressStream потребуется создать класс, который будет перехватывать операции записи в поток и вызывать обработчик прогресса:

type
  TOnProgressEvent = procedure(const ACount: Int64) of object;
  TProgressStream = class(TStream)
  strict private
    FStream: TStream;
  protected
    function GetSize: Int64; override;
    procedure SetSize(NewSize: Longint); overload; override;
    procedure SetSize(const NewSize: Int64); overload; override;
  public
    OnProgress: TOnProgressEvent;
    // Остальные методы TStream переопределяются аналогично
    constructor Create(const AStream: TStream);
    // ...
  end;

В конструкторе Create инициализируется внутренний поток, а в методе Write вызывается обработчик прогресса:

function TProgressStream.Write(const Buffer; Count: Longint): Longint;
begin
  Result := FStream.Write(Buffer, Count);
  if Assigned(OnProgress) then
  begin
    OnProgress(Count);
  end;
end;

Использование такого подхода позволяет отслеживать прогресс скачивания файла, даже если в библиотеке Embarcadero's AmazonAPI напрямую такая возможность не предусмотрена.

Создано по материалам из источника по ссылке.

Вопрос пользователя связан с необходимостью отслеживания прогресса загрузки объектов из сервиса Amazon S3 с использованием библиотеки Embarcadero's AmazonAPI, и интересует наличие в классе `TAmazonStorageService` механизмов для мониторинга этого процесса

Комментарии и вопросы

Получайте свежие новости и обновления по Object Pascal, Delphi и Lazarus прямо в свой смартфон. Подпишитесь на наш Telegram-канал delphi_kansoftware и будьте в курсе последних тенденций в разработке под Linux, Windows, Android и iOS

:: Главная :: Процессы и Сервисы ::