com.azure.storage.blob

Class BlobServiceAsyncClient

java.lang.Object

com.azure.storage.blob.BlobServiceAsyncClient

public final class BlobServiceAsyncClient
extends Object

Client to a storage account. It may only be instantiated through a BlobServiceClientBuilder. This class does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers.

This client contains operations on a blob. Operations on a container are available on BlobContainerAsyncClient through BlobServiceAsyncClient.getBlobContainerAsyncClient(String), and operations on a blob are available on BlobAsyncClient.

Please see here for more information on containers.

Note this client is an async client that returns reactive responses from Spring Reactor Core project (https://projectreactor.io/). Calling the methods in this client will NOT start the actual network operation, until .subscribe() is called on the reactive response. You can simply convert one of these responses to a CompletableFuture object through Mono.toFuture().

Method Summary

Modifier and Type	Method and Description
Mono<BlobContainerAsyncClient>	createBlobContainer(String containerName) Creates a new container within a storage account.
Mono<Response<BlobContainerAsyncClient>>	createBlobContainerWithResponse(String containerName, Map<String,String> metadata, PublicAccessType accessType) Creates a new container within a storage account.
Mono<Void>	deleteBlobContainer(String containerName) Deletes the specified container in the storage account.
Mono<Response<Void>>	deleteBlobContainerWithResponse(String containerName) Deletes the specified container in the storage account.
Mono<StorageAccountInfo>	getAccountInfo() Returns the sku name and account kind for the account.
Mono<Response<StorageAccountInfo>>	getAccountInfoWithResponse() Returns the sku name and account kind for the account.
String	getAccountName() Get associated account name.
String	getAccountUrl() Gets the URL of the storage account represented by this client.
BlobContainerAsyncClient	getBlobContainerAsyncClient(String containerName) Initializes a BlobContainerAsyncClient object pointing to the specified container.
HttpPipeline	getHttpPipeline() Gets the HttpPipeline powering this client.
Mono<BlobServiceProperties>	getProperties() Gets the properties of a storage account’s Blob service.
Mono<Response<BlobServiceProperties>>	getPropertiesWithResponse() Gets the properties of a storage account’s Blob service.
BlobServiceVersion	getServiceVersion() Gets the service version the client is using.
Mono<BlobServiceStatistics>	getStatistics() Retrieves statistics related to replication for the Blob service.
Mono<Response<BlobServiceStatistics>>	getStatisticsWithResponse() Retrieves statistics related to replication for the Blob service.
Mono<UserDelegationKey>	getUserDelegationKey(OffsetDateTime start, OffsetDateTime expiry) Gets a user delegation key for use with this account's blob storage.
Mono<Response<UserDelegationKey>>	getUserDelegationKeyWithResponse(OffsetDateTime start, OffsetDateTime expiry) Gets a user delegation key for use with this account's blob storage.
PagedFlux<BlobContainerItem>	listBlobContainers() Returns a reactive Publisher emitting all the containers in this account lazily as needed.
PagedFlux<BlobContainerItem>	listBlobContainers(ListBlobContainersOptions options) Returns a reactive Publisher emitting all the containers in this account lazily as needed.
Mono<Void>	setProperties(BlobServiceProperties properties) Sets properties for a storage account's Blob service endpoint.
Mono<Response<Void>>	setPropertiesWithResponse(BlobServiceProperties properties) Sets properties for a storage account's Blob service endpoint.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getBlobContainerAsyncClient

public BlobContainerAsyncClient getBlobContainerAsyncClient(String containerName)

Initializes a BlobContainerAsyncClient object pointing to the specified container. This method does not create a container. It simply constructs the URL to the container and offers access to methods relevant to containers.

Code Samples

BlobContainerAsyncClient blobContainerAsyncClient = client.getBlobContainerAsyncClient("containerName");

Parameters:

containerName - The name of the container to point to. A value of null or empty string will be interpreted as pointing to the root container and will be replaced by "$root".

Returns:

A BlobContainerAsyncClient object pointing to the specified container

getHttpPipeline

public HttpPipeline getHttpPipeline()

Gets the HttpPipeline powering this client.

Returns:

The pipeline.

getServiceVersion

public BlobServiceVersion getServiceVersion()

Gets the service version the client is using.

Returns:

the service version the client is using.

createBlobContainer

public Mono<BlobContainerAsyncClient> createBlobContainer(String containerName)

Creates a new container within a storage account. If a container with the same name already exists, the operation fails. For more information, see the Azure Docs.

Code Samples

BlobContainerAsyncClient blobContainerAsyncClient =
    client.createBlobContainer("containerName").block();

Parameters:

containerName - Name of the container to create

Returns:

A Mono containing a BlobContainerAsyncClient used to interact with the container created.

createBlobContainerWithResponse

public Mono<Response<BlobContainerAsyncClient>> createBlobContainerWithResponse(String containerName,
                                                                                Map<String,String> metadata,
                                                                                PublicAccessType accessType)

Creates a new container within a storage account. If a container with the same name already exists, the operation fails. For more information, see the Azure Docs.

Code Samples

Map<String, String> metadata = Collections.singletonMap("metadata", "value");

BlobContainerAsyncClient containerClient = client
    .createBlobContainerWithResponse("containerName", metadata, PublicAccessType.CONTAINER).block().getValue();

Parameters:

containerName - Name of the container to create

metadata - Metadata to associate with the container

accessType - Specifies how the data in this container is available to the public. See the x-ms-blob-public-access header in the Azure Docs for more information. Pass null for no public access.

Returns:

A Mono containing a Response whose value contains a BlobContainerAsyncClient used to interact with the container created.

deleteBlobContainer

public Mono<Void> deleteBlobContainer(String containerName)

Deletes the specified container in the storage account. If the container doesn't exist the operation fails. For more information see the Azure Docs.

Code Samples

client.deleteBlobContainer("containerName").subscribe(
    response -> System.out.printf("Delete container completed%n"),
    error -> System.out.printf("Delete container failed: %s%n", error));

Parameters:

containerName - Name of the container to delete

Returns:

A Mono containing containing status code and HTTP headers

deleteBlobContainerWithResponse

public Mono<Response<Void>> deleteBlobContainerWithResponse(String containerName)

Deletes the specified container in the storage account. If the container doesn't exist the operation fails. For more information see the Azure Docs.

Code Samples

Context context = new Context("Key", "Value");
client.deleteBlobContainerWithResponse("containerName").subscribe(response ->
    System.out.printf("Delete container completed with status %d%n", response.getStatusCode()));

Parameters:

containerName - Name of the container to delete

Returns:

A Mono containing containing status code and HTTP headers

getAccountUrl

public String getAccountUrl()

Gets the URL of the storage account represented by this client.

Returns:

the URL.

listBlobContainers

public PagedFlux<BlobContainerItem> listBlobContainers()

Returns a reactive Publisher emitting all the containers in this account lazily as needed. For more information, see the Azure Docs.

Code Samples

client.listBlobContainers().subscribe(container -> System.out.printf("Name: %s%n", container.getName()));

Returns:

A reactive response emitting the list of containers.

listBlobContainers

public PagedFlux<BlobContainerItem> listBlobContainers(ListBlobContainersOptions options)

Returns a reactive Publisher emitting all the containers in this account lazily as needed. For more information, see the Azure Docs.

Code Samples

ListBlobContainersOptions options = new ListBlobContainersOptions()
    .setPrefix("containerNamePrefixToMatch")
    .setDetails(new BlobContainerListDetails().setRetrieveMetadata(true));

client.listBlobContainers(options).subscribe(container -> System.out.printf("Name: %s%n", container.getName()));

Parameters:

options - A ListBlobContainersOptions which specifies what data should be returned by the service.

Returns:

A reactive response emitting the list of containers.

getProperties

public Mono<BlobServiceProperties> getProperties()

Gets the properties of a storage account’s Blob service. For more information, see the Azure Docs.

Code Samples

client.getProperties().subscribe(response ->
    System.out.printf("Hour metrics enabled: %b, Minute metrics enabled: %b%n",
        response.getHourMetrics().isEnabled(),
        response.getMinuteMetrics().isEnabled()));

Returns:

A reactive response containing the storage account properties.

getPropertiesWithResponse

public Mono<Response<BlobServiceProperties>> getPropertiesWithResponse()

Gets the properties of a storage account’s Blob service. For more information, see the Azure Docs.

Code Samples

client.getPropertiesWithResponse().subscribe(response ->
    System.out.printf("Hour metrics enabled: %b, Minute metrics enabled: %b%n",
        response.getValue().getHourMetrics().isEnabled(),
        response.getValue().getMinuteMetrics().isEnabled()));

Returns:

A Mono containing a Response whose value contains the storage account properties.

setProperties

public Mono<Void> setProperties(BlobServiceProperties properties)

Sets properties for a storage account's Blob service endpoint. For more information, see the Azure Docs. Note that setting the default service version has no effect when using this client because this client explicitly sets the version header on each request, overriding the default.

Code Samples

BlobRetentionPolicy loggingRetentionPolicy = new BlobRetentionPolicy().setEnabled(true).setDays(3);
BlobRetentionPolicy metricsRetentionPolicy = new BlobRetentionPolicy().setEnabled(true).setDays(1);

BlobServiceProperties properties = new BlobServiceProperties()
    .setLogging(new BlobAnalyticsLogging()
        .setWrite(true)
        .setDelete(true)
        .setRetentionPolicy(loggingRetentionPolicy))
    .setHourMetrics(new BlobMetrics()
        .setEnabled(true)
        .setRetentionPolicy(metricsRetentionPolicy))
    .setMinuteMetrics(new BlobMetrics()
        .setEnabled(true)
        .setRetentionPolicy(metricsRetentionPolicy));

client.setProperties(properties).subscribe(
    response -> System.out.printf("Setting properties completed%n"),
    error -> System.out.printf("Setting properties failed: %s%n", error));

Parameters:

properties - Configures the service.

Returns:

A Mono containing the storage account properties.

setPropertiesWithResponse

public Mono<Response<Void>> setPropertiesWithResponse(BlobServiceProperties properties)

Sets properties for a storage account's Blob service endpoint. For more information, see the Azure Docs. Note that setting the default service version has no effect when using this client because this client explicitly sets the version header on each request, overriding the default.

Code Samples

BlobRetentionPolicy loggingRetentionPolicy = new BlobRetentionPolicy().setEnabled(true).setDays(3);
BlobRetentionPolicy metricsRetentionPolicy = new BlobRetentionPolicy().setEnabled(true).setDays(1);

BlobServiceProperties properties = new BlobServiceProperties()
    .setLogging(new BlobAnalyticsLogging()
        .setWrite(true)
        .setDelete(true)
        .setRetentionPolicy(loggingRetentionPolicy))
    .setHourMetrics(new BlobMetrics()
        .setEnabled(true)
        .setRetentionPolicy(metricsRetentionPolicy))
    .setMinuteMetrics(new BlobMetrics()
        .setEnabled(true)
        .setRetentionPolicy(metricsRetentionPolicy));

client.setPropertiesWithResponse(properties).subscribe(response ->
    System.out.printf("Setting properties completed with status %d%n", response.getStatusCode()));

Parameters:

properties - Configures the service.

Returns:

A Mono containing the storage account properties.

getUserDelegationKey

public Mono<UserDelegationKey> getUserDelegationKey(OffsetDateTime start,
                                                    OffsetDateTime expiry)

Gets a user delegation key for use with this account's blob storage. Note: This method call is only valid when using TokenCredential in this object's HttpPipeline.

Code Samples

client.getUserDelegationKey(delegationKeyStartTime, delegationKeyExpiryTime).subscribe(response ->
    System.out.printf("User delegation key: %s%n", response.getValue()));

Parameters:

start - Start time for the key's validity. Null indicates immediate start.

expiry - Expiration of the key's validity.

Returns:

A Mono containing the user delegation key.

Throws:

IllegalArgumentException - If start isn't null and is after expiry.

NullPointerException - If expiry is null.

getUserDelegationKeyWithResponse

public Mono<Response<UserDelegationKey>> getUserDelegationKeyWithResponse(OffsetDateTime start,
                                                                          OffsetDateTime expiry)

Gets a user delegation key for use with this account's blob storage. Note: This method call is only valid when using TokenCredential in this object's HttpPipeline.

Code Samples

client.getUserDelegationKeyWithResponse(delegationKeyStartTime, delegationKeyExpiryTime).subscribe(response ->
    System.out.printf("User delegation key: %s%n", response.getValue().getValue()));

Parameters:

start - Start time for the key's validity. Null indicates immediate start.

expiry - Expiration of the key's validity.

Returns:

A Mono containing a Response whose value containing the user delegation key.

Throws:

IllegalArgumentException - If start isn't null and is after expiry.

NullPointerException - If expiry is null.

getStatistics

public Mono<BlobServiceStatistics> getStatistics()

Retrieves statistics related to replication for the Blob service. It is only available on the secondary location endpoint when read-access geo-redundant replication is enabled for the storage account. For more information, see the Azure Docs.

Code Samples

client.getStatistics().subscribe(response ->
    System.out.printf("Geo-replication status: %s%n", response.getGeoReplication().getStatus()));

Returns:

A Mono containing the storage account statistics.

getStatisticsWithResponse

public Mono<Response<BlobServiceStatistics>> getStatisticsWithResponse()

Retrieves statistics related to replication for the Blob service. It is only available on the secondary location endpoint when read-access geo-redundant replication is enabled for the storage account. For more information, see the Azure Docs.

Code Samples

client.getStatisticsWithResponse().subscribe(response ->
    System.out.printf("Geo-replication status: %s%n", response.getValue().getGeoReplication().getStatus()));

Returns:

A Mono containing a Response whose value containing the storage account statistics.

getAccountInfo

public Mono<StorageAccountInfo> getAccountInfo()

Returns the sku name and account kind for the account. For more information, please see the Azure Docs.

Code Samples

client.getAccountInfo().subscribe(response ->
    System.out.printf("Account kind: %s, SKU: %s%n", response.getAccountKind(), response.getSkuName()));

Returns:

A Mono containing containing the storage account info.

getAccountInfoWithResponse

public Mono<Response<StorageAccountInfo>> getAccountInfoWithResponse()

Returns the sku name and account kind for the account. For more information, please see the Azure Docs.

Code Samples

client.getAccountInfoWithResponse().subscribe(response ->
    System.out.printf("Account kind: %s, SKU: %s%n", response.getValue().getAccountKind(),
        response.getValue().getSkuName()));

Returns:

A Mono containing a Response whose value the storage account info.

getAccountName

public String getAccountName()

Get associated account name.

Returns:

account name associated with this storage resource.