Skip to content


Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
tree: afa8e0aeed
170 lines (135 sloc) 6.222 kb
/** * Copyright 2013 Microsoft Corporation
* 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
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* See the License for the specific language governing permissions and
* limitations under the License.
require_once 'WindowsAzure\WindowsAzure.php';
use WindowsAzure\Common\ServicesBuilder;
use WindowsAzure\Common\ServiceException;
use WindowsAzure\Common\CloudConfigurationManager;
use WindowsAzure\Blob\Models\Block;
use WindowsAzure\Blob\Models\CreateContainerOptions;
use WindowsAzure\Blob\Models\ListContainersOptions;
define("CONTAINERNAME", "mycontainer");
define("BLOCKBLOBNAME", "myblockblob");
define("BLOCKSIZE", 4 * 1024 * 1024); // Size of the block, modify if needed.
define("PADLENGTH", 5); // Size of the string used for the block ID, modify if needed.
define("FILENAME", "myfile.txt"); // Local file to upload as a block blob.
function createContainerIfNotExists($blobRestProxy)
// See if the container already exists.
$listContainersOptions = new ListContainersOptions;
$listContainersResult = $blobRestProxy->listContainers($listContainersOptions);
$containerExists = false;
foreach ($listContainersResult->getContainers() as $container)
if ($container->getName() == CONTAINERNAME)
// The container exists.
$containerExists = true;
// No need to keep checking.
if (!$containerExists)
echo "Creating container.\n";
echo "Container '" . CONTAINERNAME . "' successfully created.\n";
try {
echo "Beginning processing.\n";
Use CloudConfigurationManager::getConnectionString to retrieve
the connection string whose name (in this example) is
By default, the CloudConfigurationManager::getConnectionString method
will look for an environment variable with the name that is passed in
as the method parameter, and then assign the environment variable's
value as the return value.
For example, if you want to use the storage emulator, start
the storage emulator, set an environment variable through a technique
such as
set StorageConnectionString=UseDevelopmentStorage=true
and then run this sample at a command prompt that has the
StorageConnectionString as an active environment variable.
If you want to use a production storage account, set the
environment variable through a technique such as
set StorageConnectionString=DefaultEndpointsProtocol=http;AccountName=your_account_name;AccountKey=your_account_key
(Substitute your storage account name and account key for
your_account_name and your_account_key, respectively.)
Then run this sample at a command prompt that has the
StorageConnectionString as an active environment variable.
The format for the storage connection string itself is documented at
If you do not want to use an environment variable as the source
for the connection string name, you can register other sources
via the CloudCofigurationManager::registerSource method.
$connectionString = CloudConfigurationManager::getConnectionString("StorageConnectionString");
if (null == $connectionString || "" == $connectionString)
echo "Did not find a connection string whose name is 'StorageConnectionString'.";
$blobRestProxy = ServicesBuilder::getInstance()->createBlobService($connectionString);
echo "Using the '" . CONTAINERNAME . "' container and the '" . BLOCKBLOBNAME . "' blob.\n";
echo "Using file '" . FILENAME . "'\n";
if (!file_exists(FILENAME))
echo "The '" . FILENAME . "' file does not exist. Exiting program.\n";
$handle = fopen(FILENAME, "r");
// Upload the blob using blocks.
$counter = 1;
$blockIds = array();
while (!feof($handle))
$blockId = str_pad($counter, PADLENGTH, "0", STR_PAD_LEFT);
echo "Processing block $blockId.\n";
$block = new Block();
array_push($blockIds, $block);
$data = fread($handle, BLOCKSIZE);
// Upload the block.
$blobRestProxy->createBlobBlock(CONTAINERNAME, BLOCKBLOBNAME, base64_encode($blockId), $data);
// Done creating the blocks. Close the file and commit the blocks.
echo "Commiting the blocks.\n";
$blobRestProxy->commitBlobBlocks(CONTAINERNAME, BLOCKBLOBNAME, $blockIds);
echo "Done processing.\n";
catch(ServiceException $serviceException)
// Handle exception based on error codes and messages.
// Error codes and messages are here:
echo "ServiceException encountered.\n";
$code = $serviceException->getCode();
$error_message = $serviceException->getMessage();
echo "$code: $error_message";
catch (Exception $exception)
echo "Exception encountered.\n";
$code = $exception->getCode();
$error_message = $exception->getMessage();
echo "$code: $error_message";
Jump to Line
Something went wrong with that request. Please try again.