2025-06-29 14:35:33 +03:00
|
|
|
URL = "storage-155.s3hoster.by";
|
|
|
|
|
AccessKey = "BRN5RKJE67...";
|
|
|
|
|
SecretKey = "NNhv+i9PrytpT8Tu0C1N...";
|
2024-11-21 11:30:08 +03:00
|
|
|
Region = "BTC";
|
|
|
|
|
|
|
|
|
|
BasicData = OPI_S3.GetBasicDataStructure(URL, AccessKey, SecretKey, Region);
|
|
|
|
|
|
2025-09-01 14:51:24 +03:00
|
|
|
Name = "fileChunked.mp3";
|
2024-11-21 11:30:08 +03:00
|
|
|
|
2025-09-01 14:51:24 +03:00
|
|
|
Directory = True; // Formation URL in path-style
|
|
|
|
|
Bucket = "opi-dirbucket3";
|
2025-06-29 14:35:33 +03:00
|
|
|
Entity = "https://hut.openintegrations.dev/test_data/song.mp3"; // URL, Path or Binary Data
|
2025-04-16 22:15:09 +03:00
|
|
|
Entity = OPI_HTTPRequests.Get(Entity);
|
2024-11-21 11:30:08 +03:00
|
|
|
|
2025-09-01 14:51:24 +03:00
|
|
|
Result = OPI_S3.InitPartsUpload(Name, Bucket, BasicData, , Directory);
|
2024-11-21 11:30:08 +03:00
|
|
|
|
|
|
|
|
UploadID = Result["response"]["InitiateMultipartUploadResult"]["UploadId"];
|
|
|
|
|
TotalSize = Entity.Size();
|
|
|
|
|
ChunkSize = 5242880;
|
|
|
|
|
BytesRead = 0;
|
|
|
|
|
PartNumber = 1;
|
|
|
|
|
|
|
|
|
|
DataReader = New DataReader(Entity);
|
|
|
|
|
SourceStream = DataReader.SourceStream();
|
|
|
|
|
TagsArray = New Array;
|
|
|
|
|
|
2024-12-15 15:57:20 +03:00
|
|
|
While BytesRead < TotalSize Do
|
2024-11-21 11:30:08 +03:00
|
|
|
|
|
|
|
|
CurrentReading = DataReader.Read(ChunkSize);
|
|
|
|
|
CurrentData = CurrentReading.GetBinaryData();
|
|
|
|
|
|
|
|
|
|
If CurrentData.Size() = 0 Then
|
|
|
|
|
Break;
|
|
|
|
|
EndIf;
|
|
|
|
|
|
2025-09-01 14:51:24 +03:00
|
|
|
Result = OPI_S3.UploadObjectPart(Name
|
|
|
|
|
, Bucket
|
|
|
|
|
, BasicData
|
|
|
|
|
, UploadID
|
|
|
|
|
, PartNumber
|
|
|
|
|
, CurrentData
|
|
|
|
|
, Directory);
|
2024-11-21 11:30:08 +03:00
|
|
|
|
|
|
|
|
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
|
|
|
|
|
|
|
|
|
|
BytesRead = SourceStream.CurrentPosition();
|
2024-11-23 10:32:51 +03:00
|
|
|
|
|
|
|
|
ETag = Result["headers"]["Etag"];
|
|
|
|
|
ETag = ?(ETag = Undefined, Result["headers"]["ETag"], ETag);
|
|
|
|
|
|
|
|
|
|
TagsArray.Add(ETag);
|
2024-11-21 11:30:08 +03:00
|
|
|
|
|
|
|
|
PartNumber = PartNumber + 1;
|
|
|
|
|
|
|
|
|
|
EndDo;
|
|
|
|
|
|
2025-09-01 14:51:24 +03:00
|
|
|
Result = OPI_S3.FinishPartsUpload(Name, Bucket, BasicData, UploadID, TagsArray, , Directory);
|