AppendBlobAsyncClient Classe

@Deprecated
public static final int MAX_APPEND_BLOCK_BYTES

Déprécié

Indique le nombre maximal d’octets pouvant être envoyés dans un appel à appendBlock.

@Deprecated
public static final int MAX_BLOCKS

Déprécié

Indique le nombre maximal de blocs autorisés dans un objet blob d’ajout.

public Mono appendBlock(Flux data, long length)

Valide un nouveau bloc de données à la fin de l’objet blob d’ajout existant.

Notez que les données passées doivent être relues si les nouvelles tentatives sont activées (valeur par défaut). En d’autres termes, le Flux doit produire les mêmes données chaque fois qu’il est abonné. Pour les versions de service 2022-11-02 et ultérieures, la taille de bloc maximale est de 100 Mo. Pour les versions précédentes, la taille maximale du bloc est de 4 Mo. Pour plus d’informations, consultez Azure Docs.

Exemples de code

client.appendBlock(data, length).subscribe(response ->
     System.out.printf("AppendBlob has %d committed blocks%n", response.getBlobCommittedBlockCount()));

Paramètres:

Retours:

public Mono appendBlockFromUrl(String sourceUrl, BlobRange sourceRange)

Valide un nouveau bloc de données d’un autre objet blob à la fin de cet objet blob d’ajout.

Exemples de code

client.appendBlockFromUrl(sourceUrl, new BlobRange(offset, count)).subscribe(response ->
     System.out.printf("AppendBlob has %d committed blocks%n", response.getBlobCommittedBlockCount()));

Paramètres:

Retours:

public Mono> appendBlockFromUrlWithResponse(AppendBlobAppendBlockFromUrlOptions options)

Valide un nouveau bloc de données d’un autre objet blob à la fin de cet objet blob d’ajout.

Exemples de code

AppendBlobRequestConditions appendBlobRequestConditions = new AppendBlobRequestConditions()
     .setAppendPosition(POSITION)
     .setMaxSize(maxSize);

 BlobRequestConditions modifiedRequestConditions = new BlobRequestConditions()
     .setIfUnmodifiedSince(OffsetDateTime.now().minusDays(3));

 client.appendBlockFromUrlWithResponse(new AppendBlobAppendBlockFromUrlOptions(sourceUrl)
     .setSourceRange(new BlobRange(offset, count))
     .setDestinationRequestConditions(appendBlobRequestConditions)
     .setSourceRequestConditions(modifiedRequestConditions)).subscribe(response ->
     System.out.printf("AppendBlob has %d committed blocks%n", response.getValue().getBlobCommittedBlockCount()));

Paramètres:

Retours:

public Mono> appendBlockFromUrlWithResponse(String sourceUrl, BlobRange sourceRange, byte[] sourceContentMD5, AppendBlobRequestConditions destRequestConditions, BlobRequestConditions sourceRequestConditions)

Valide un nouveau bloc de données d’un autre objet blob à la fin de cet objet blob d’ajout.

Exemples de code

AppendBlobRequestConditions appendBlobRequestConditions = new AppendBlobRequestConditions()
     .setAppendPosition(POSITION)
     .setMaxSize(maxSize);

 BlobRequestConditions modifiedRequestConditions = new BlobRequestConditions()
     .setIfUnmodifiedSince(OffsetDateTime.now().minusDays(3));

 client.appendBlockFromUrlWithResponse(sourceUrl, new BlobRange(offset, count), null,
     appendBlobRequestConditions, modifiedRequestConditions).subscribe(response ->
     System.out.printf("AppendBlob has %d committed blocks%n", response.getValue().getBlobCommittedBlockCount()));

Paramètres:

Retours:

public Mono> appendBlockWithResponse(Flux data, long length, byte[] contentMd5, AppendBlobRequestConditions appendBlobRequestConditions)

Valide un nouveau bloc de données à la fin de l’objet blob d’ajout existant.

Notez que les données passées doivent être relues si les nouvelles tentatives sont activées (valeur par défaut). En d’autres termes, le Flux doit produire les mêmes données chaque fois qu’il est abonné. Pour les versions de service 2022-11-02 et ultérieures, la taille maximale du bloc est de 100 Mo. Pour les versions précédentes, la taille maximale du bloc est de 4 Mo. Pour plus d’informations, consultez Azure Docs.

Exemples de code

byte[] md5 = MessageDigest.getInstance("MD5").digest("data".getBytes(StandardCharsets.UTF_8));
 AppendBlobRequestConditions requestConditions = new AppendBlobRequestConditions()
     .setAppendPosition(POSITION)
     .setMaxSize(maxSize);

 client.appendBlockWithResponse(data, length, md5, requestConditions).subscribe(response ->
     System.out.printf("AppendBlob has %d committed blocks%n", response.getValue().getBlobCommittedBlockCount()));

Paramètres:

Retours:

public Mono create()

Crée un objet blob d’ajout de longueur 0. Appelez appendBlock pour ajouter des données à un objet blob d’ajout. Par défaut, cette méthode ne remplace pas un objet blob existant.

Exemples de code

client.create().subscribe(response ->
     System.out.printf("Created AppendBlob at %s%n", response.getLastModified()));

Retours:

public Mono create(boolean overwrite)

Crée un objet blob d’ajout de longueur 0. Appelez appendBlock pour ajouter des données à un objet blob d’ajout.

Exemples de code

boolean overwrite = false; // Default behavior
 client.create(overwrite).subscribe(response ->
     System.out.printf("Created AppendBlob at %s%n", response.getLastModified()));

Paramètres:

Retours:

public Mono createIfNotExists()

Crée un objet blob d’ajout de longueur 0 s’il n’existe pas. Appelez appendBlock pour ajouter des données à un objet blob d’ajout.

Exemples de code

client.createIfNotExists().subscribe(response ->
     System.out.printf("Created AppendBlob at %s%n", response.getLastModified()));

Retours:

public Mono> createIfNotExistsWithResponse(AppendBlobCreateOptions options)

Crée un objet blob d’ajout de longueur 0 s’il n’existe pas. Appelez appendBlock pour ajouter des données à un objet blob d’ajout.

Exemples de code

BlobHttpHeaders headers = new BlobHttpHeaders()
     .setContentType("binary")
     .setContentLanguage("en-US");
 Map<String, String> metadata = Collections.singletonMap("metadata", "value");
 Map<String, String> tags = Collections.singletonMap("tag", "value");

 client.createIfNotExistsWithResponse(new AppendBlobCreateOptions().setHeaders(headers)
     .setMetadata(metadata).setTags(tags)).subscribe(response -> {
         if (response.getStatusCode() == 409) {
             System.out.println("Already exists.");
         } else {
             System.out.println("successfully created.");
         }
     });

Paramètres:

Retours:

public Mono> createWithResponse(BlobHttpHeaders headers, Map metadata, BlobRequestConditions requestConditions)

Crée un objet blob d’ajout de longueur 0. Appelez appendBlock pour ajouter des données à un objet blob d’ajout.

Pour éviter le remplacement, passez « * » à setIfNoneMatch(String ifNoneMatch).

Exemples de code

BlobHttpHeaders headers = new BlobHttpHeaders()
     .setContentType("binary")
     .setContentLanguage("en-US");
 Map<String, String> metadata = Collections.singletonMap("metadata", "value");
 BlobRequestConditions requestConditions = new BlobRequestConditions().setLeaseId(leaseId)
     .setIfUnmodifiedSince(OffsetDateTime.now().minusDays(3));

 client.createWithResponse(headers, metadata, requestConditions).subscribe(response ->
     System.out.printf("Created AppendBlob at %s%n", response.getValue().getLastModified()));

Paramètres:

Retours:

public Mono> createWithResponse(AppendBlobCreateOptions options)

Crée un objet blob d’ajout de longueur 0. Appelez appendBlock pour ajouter des données à un objet blob d’ajout.

Pour éviter le remplacement, passez « * » à setIfNoneMatch(String ifNoneMatch).

Exemples de code

BlobHttpHeaders headers = new BlobHttpHeaders()
     .setContentType("binary")
     .setContentLanguage("en-US");
 Map<String, String> metadata = Collections.singletonMap("metadata", "value");
 Map<String, String> tags = Collections.singletonMap("tag", "value");
 BlobRequestConditions requestConditions = new BlobRequestConditions().setLeaseId(leaseId)
     .setIfUnmodifiedSince(OffsetDateTime.now().minusDays(3));

 client.createWithResponse(new AppendBlobCreateOptions().setHeaders(headers).setMetadata(metadata)
     .setTags(tags).setRequestConditions(requestConditions)).subscribe(response ->
     System.out.printf("Created AppendBlob at %s%n", response.getValue().getLastModified()));

Paramètres:

Retours:

public AppendBlobAsyncClient getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)

Crée un nouveau AppendBlobAsyncClient avec le customerProvidedKey spécifié.

Remplacements:

Paramètres:

Retours:

public AppendBlobAsyncClient getEncryptionScopeAsyncClient(String encryptionScope)

Crée un nouveau AppendBlobAsyncClient avec le encryptionScope spécifié.

Remplacements:

Paramètres:

Retours:

public int getMaxAppendBlockBytes()

Obtenez le nombre maximal d’octets de blocs d’ajout en fonction de la version du service utilisée. Les versions de service 2022-11-02 et ultérieures prennent en charge le chargement d’octets de blocs jusqu’à 100 Mo, toutes les anciennes versions de service prennent en charge jusqu’à 4 Mo.

Retours:

public int getMaxBlocks()

Obtenez le nombre maximal de blocs autorisés dans un objet blob d’ajout.

Retours:

public Mono seal()

Scelle un objet blob d’ajout, ce qui le rend en lecture seule. Les ajouts suivants échouent.

Exemples de code

client.seal().subscribe(response -> System.out.println("Sealed AppendBlob"));

Retours:

public Mono> sealWithResponse(AppendBlobSealOptions options)

Scelle un objet blob d’ajout, ce qui le rend en lecture seule. Les ajouts suivants échouent.

Exemples de code

AppendBlobRequestConditions requestConditions = new AppendBlobRequestConditions().setLeaseId(leaseId)
     .setIfUnmodifiedSince(OffsetDateTime.now().minusDays(3));

 client.sealWithResponse(new AppendBlobSealOptions().setRequestConditions(requestConditions))
     .subscribe(response -> System.out.println("Sealed AppendBlob"));

Paramètres:

Retours: