123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151 |
- <?php
- if (file_exists ( 'vendor/autoload.php' )) {
- require 'vendor/autoload.php';
- } else {
- require '../vendor/autoload.php';
- }
- if (file_exists ( 'obs-autoloader.php' )) {
- require 'obs-autoloader.php';
- } else {
- require '../obs-autoloader.php';
- }
- use Obs\ObsClient;
- use GuzzleHttp\Client;
- use GuzzleHttp\Exception\ClientException;
- $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';
- $obsClient = ObsClient::factory ( [
- 'key' => $ak,
- 'secret' => $sk,
- 'endpoint' => $endpoint,
- 'socket_timeout' => 30,
- 'connect_timeout' => 10
- ] );
- $httpClient = new Client(['verify' => false]);
- $method = 'PUT';
- $res = $obsClient -> createSignedUrl(['Bucket' => $bucketName, 'Method' => $method]);
- doAction('Create bucket', $method, $res['SignedUrl']);
- $method = 'PUT';
- $content = '<CORSConfiguration><CORSRule><AllowedMethod>PUT</AllowedMethod><AllowedOrigin>http://www.a.com</AllowedOrigin><AllowedHeader>header1</AllowedHeader><MaxAgeSeconds>100</MaxAgeSeconds><ExposeHeader>header2</ExposeHeader></CORSRule></CORSConfiguration>';
- $headers = ['Content-Length'=> strval(strlen($content)), 'Content-MD5' => base64_encode(md5($content, true))];
- $res = $obsClient -> createSignedUrl(['Bucket' => $bucketName, 'Method' => $method, 'SpecialParam' => 'cors', 'Headers' => $headers]);
- doAction('Set bucket cors ', $method, $res['SignedUrl'], $content, $res['ActualSignedRequestHeaders']);
- $method = 'GET';
- $res= $obsClient -> createSignedUrl(['Bucket' => $bucketName, 'Method' => $method, 'SpecialParam' => 'cors']);
- doAction('Get bucket cors ', $method, $res['SignedUrl']);
- $method = 'DELETE';
- $res= $obsClient -> createSignedUrl(['Bucket' => $bucketName, 'Method' => $method, 'SpecialParam' => 'cors']);
- doAction('Delete bucket cors ', $method, $res['SignedUrl']);
- $method = 'PUT';
- $content = 'Hello OBS';
- $headers = ['Content-Length'=> strval(strlen($content))];
- $res = $obsClient -> createSignedUrl(['Method' => $method, 'Bucket' => $bucketName, 'Key' => $objectKey, 'Headers'=> $headers]);
- doAction('Create object', $method, $res['SignedUrl'], $content, $res['ActualSignedRequestHeaders']);
-
- $method = 'GET';
- $res = $obsClient -> createSignedUrl(['Method' => $method, 'Bucket' => $bucketName, 'Key' => $objectKey]);
- doAction('Get object', $method, $res['SignedUrl']);
- $method = 'PUT';
- $headers = ['x-amz-acl'=> ObsClient::AclPublicRead];
- $res = $obsClient -> createSignedUrl(['Method' => $method, 'Bucket' => $bucketName, 'Key' => $objectKey, 'Headers'=> $headers, 'SpecialParam' => 'acl']);
- doAction('Set object Acl', $method, $res['SignedUrl'], null, $res['ActualSignedRequestHeaders']);
- $method = 'GET';
- $res = $obsClient -> createSignedUrl(['Method' => $method, 'Bucket' => $bucketName, 'Key' => $objectKey, 'SpecialParam' => 'acl']);
- doAction('Get object Acl', $method, $res['SignedUrl']);
- $method = 'DELETE';
- $res = $obsClient -> createSignedUrl(['Method' => $method, 'Bucket' => $bucketName, 'Key' => $objectKey]);
- doAction('Delete object', $method, $res['SignedUrl']);
- $method = 'DELETE';
- $res = $obsClient -> createSignedUrl(['Bucket' => $bucketName, 'Method' => $method]);
- doAction('Delete bucket', $method, $res['SignedUrl']);
- function doAction($msg, $method, $url, $content=null, $headers=null){
- global $httpClient;
-
- try{
- $response = $httpClient -> request($method, $url, ['body' => $content, 'headers'=> $headers]);
- printf("%s using temporary signature url:\n", $msg);
- printf("\t%s successfully.\n", $url);
- printf("\tStatus:%d\n", $response -> getStatusCode());
- printf("\tContent:%s\n", $response -> getBody() -> getContents());
- $response -> getBody()-> close();
- }catch (ClientException $ex){
- printf("%s using temporary signature url:\n", $msg);
- printf("\t%s failed!\n", $url);
- printf('Exception message:%s', $ex ->getMessage());
- }
- printf("\n");
- }
-
|