Container.CreateItemStreamAsync Méthode

Définition

Crée un élément en tant qu’opération asynchrone dans le service Azure Cosmos.

public abstract System.Threading.Tasks.Task<Microsoft.Azure.Cosmos.ResponseMessage> CreateItemStreamAsync (System.IO.Stream streamPayload, Microsoft.Azure.Cosmos.PartitionKey partitionKey, Microsoft.Azure.Cosmos.ItemRequestOptions requestOptions = default, System.Threading.CancellationToken cancellationToken = default);
abstract member CreateItemStreamAsync : System.IO.Stream * Microsoft.Azure.Cosmos.PartitionKey * Microsoft.Azure.Cosmos.ItemRequestOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<Microsoft.Azure.Cosmos.ResponseMessage>
Public MustOverride Function CreateItemStreamAsync (streamPayload As Stream, partitionKey As PartitionKey, Optional requestOptions As ItemRequestOptions = Nothing, Optional cancellationToken As CancellationToken = Nothing) As Task(Of ResponseMessage)

Paramètres

streamPayload
Stream

Stream contenant la charge utile.

partitionKey
PartitionKey

Clé de partition de l’élément.

requestOptions
ItemRequestOptions

(Facultatif) Options de la demande d’élément.

cancellationToken
CancellationToken

(Facultatif) CancellationToken représentant l’annulation de la demande.

Retours

ResponseMessage qui a été créé dans un Task objet représentant la réponse du service pour l’opération asynchrone.

Exemples

Cet exemple crée un élément dans un conteneur Cosmos.

//Create the object in Cosmos
using (ResponseMessage response = await this.Container.CreateItemStreamAsync(partitionKey: new PartitionKey("streamPartitionKey"), streamPayload: stream))
{
    if (!response.IsSuccessStatusCode)
    {
        //Handle and log exception
        return;
    }

    //Read or do other operations with the stream
    using (StreamReader streamReader = new StreamReader(response.Content))
    {
        string responseContentAsString = await streamReader.ReadToEndAsync();
    }
}

Remarques

L’opération Stream lève uniquement des exceptions côté client. Cela permet d’augmenter les performances et d’éviter la surcharge liée à la levée d’exceptions. Vérifiez le code status HTTP sur la réponse pour case activée si l’opération a échoué.

S’applique à