123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203 |
- <?php
- /**
- * Copyright 2019 Huawei Technologies Co.,Ltd.
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
- * this file except in compliance with the License. You may obtain a copy of the
- * License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software distributed
- * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
- *
- */
- /**
- * This sample demonstrates how to download an object concurrently
- * from OBS using the OBS SDK for PHP.
- */
- if (file_exists('vendor/autoload.php')) {
- require 'vendor/autoload.php';
- } else {
- require '../vendor/autoload.php'; // sample env
- }
- if (file_exists('obs-autoloader.php')) {
- require 'obs-autoloader.php';
- } else {
- require '../obs-autoloader.php'; // sample env
- }
- use Obs\ObsClient;
- use Obs\ObsException;
- $ak = '*** Provide your Access Key ***';
- $sk = '*** Provide your Secret Key ***';
- $endpoint = 'https://your-endpoint:443';
- $bucketName = 'my-obs-bucket-demo';
- $objectKey = 'my-obs-object-key-demo';
- $localFilePath = '/temp/' . $objectKey;
- /*
- * Constructs a obs client instance with your account for accessing OBS
- */
- $obsClient = ObsClient::factory([
- 'key' => $ak,
- 'secret' => $sk,
- 'endpoint' => $endpoint,
- 'socket_timeout' => 30,
- 'connect_timeout' => 10
- ]);
- try {
- /*
- * Create bucket
- */
- printf("Create a new bucket for demo\n\n");
- $obsClient->createBucket([
- 'Bucket' => $bucketName
- ]);
- $sampleFilePath = '/temp/test.txt'; // sample large file path
- // you can prepare a large file in you filesystem first
- createSampleFile($sampleFilePath);
- /*
- * Upload an object to your bucket
- */
- printf("Uploading a new object to OBS from a file\n\n");
- $obsClient->putObject([
- 'Bucket' => $bucketName,
- 'Key' => $objectKey,
- 'SourceFile' => $sampleFilePath
- ]);
- /*
- * Get size of the object and pre-create a random access file to hold object data
- */
- $resp = $obsClient->getObjectMetadata([
- 'Bucket' => $bucketName,
- 'Key' => $objectKey
- ]);
- $objectSize = $resp ['ContentLength'];
- printf("Object size from metadata:%d\n\n", $objectSize);
- $dir = dirname($localFilePath);
- if (! is_dir($dir)) {
- mkdir($dir, 0755, true);
- }
- /*
- * Calculate how many blocks to be divided
- */
- $blockSize = 5 * 1024 * 1024; // 5MB
- $blockCount = intval($objectSize / $blockSize);
- if ($objectSize % $blockSize !== 0) {
- $blockCount ++;
- }
- printf("Total blocks count:%d\n\n", $blockCount);
- /*
- * Download the object concurrently
- */
- printf("Start to download %s\n\n", $objectKey);
- $fp = fopen($localFilePath, 'w');
- $promise = null;
- for($i = 0; $i < $blockCount;) {
- $startPos = $i ++ * $blockSize;
- $endPos = ($i == $blockCount) ? $objectSize - 1 : ($i * $blockSize - 1);
- $range = sprintf('bytes=%d-%d', $startPos, $endPos);
- $p = $obsClient->getObjectAsync([
- 'Bucket' => $bucketName,
- 'Key' => $objectKey,
- 'Range' => $range
- ], function ($exception, $resp) use ($startPos, $fp, $i, $range) {
- fseek($fp, $startPos, 0);
- printf("%s\n", $range);
- try {
- while ( ! $resp ['Body']->eof() ) {
- $str = $resp ['Body']->read(65536);
- fwrite($fp, $str);
- }
- } catch ( Exception $exception ) {
- printf($exception);
- }
- $resp ['Body']->close();
- printf("Part#" . strval($i) . " done\n\n");
- });
- if ($promise === null) {
- $promise = $p;
- }
- }
- /*
- * Waiting for all blocks finished
- */
- $promise->wait();
- fclose($fp);
- if (file_exists($sampleFilePath)) {
- unlink($sampleFilePath);
- }
- /*
- * Deleting object
- */
- printf("Deleting object %s \n\n", $objectKey);
- $obsClient->deleteObject([
- 'Bucket' => $bucketName,
- 'Key' => $objectKey
- ]);
- } catch ( ObsException $e ) {
- echo 'Response Code:' . $e->getStatusCode() . PHP_EOL;
- echo 'Error Message:' . $e->getExceptionMessage() . PHP_EOL;
- echo 'Error Code:' . $e->getExceptionCode() . PHP_EOL;
- echo 'Request ID:' . $e->getRequestId() . PHP_EOL;
- echo 'Exception Type:' . $e->getExceptionType() . PHP_EOL;
- } finally{
- $obsClient->close();
- }
- function createSampleFile($filePath) {
- if (file_exists($filePath)) {
- return;
- }
- $filePath = iconv('UTF-8', 'GBK', $filePath);
- if (is_string($filePath) && $filePath !== '') {
- $fp = null;
- $dir = dirname($filePath);
- try {
- if (! is_dir($dir)) {
- mkdir($dir, 0755, true);
- }
- if (($fp = fopen($filePath, 'w'))) {
- for($i = 0; $i < 1000000; $i ++) {
- fwrite($fp, uniqid() . "\n");
- fwrite($fp, uniqid() . "\n");
- if ($i % 100 === 0) {
- fflush($fp);
- }
- }
- }
- } finally{
- if ($fp) {
- fclose($fp);
- }
- }
- }
- }
|