Partager via


QueueServiceClient class

Un QueueServiceClient représente une URL vers le service file d’attente stockage Azure qui vous permet de manipuler des files d’attente.

Extends

StorageClient

Constructeurs

QueueServiceClient(string, Pipeline)

Crée une instance de QueueServiceClient.

QueueServiceClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)

Crée une instance de QueueServiceClient.

Propriétés héritées

accountName
url

Valeur de chaîne d’URL.

Méthodes

createQueue(string, QueueCreateOptions)

Crée une file d’attente sous le compte spécifié.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/create-queue4

deleteQueue(string, QueueDeleteOptions)

Supprime définitivement la file d’attente spécifiée.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/delete-queue3

fromConnectionString(string, StoragePipelineOptions)

Crée une instance de QueueServiceClient.

generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Disponible uniquement pour QueueServiceClient construit avec des informations d’identification de clé partagée.

Génère un URI de signature d’accès partagé (SAS) de compte en fonction des propriétés et paramètres du client transmis. La signature SAS est signée par les informations d’identification de clé partagée du client.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/create-account-sas

getProperties(ServiceGetPropertiesOptions)

Obtient les propriétés du service file d’attente d’un compte de stockage, y compris les propriétés pour les règles Storage Analytics et CORS (Cross-Origin Resource Sharing).

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/get-queue-service-properties

getQueueClient(string)

Crée un objet QueueClient .

getStatistics(ServiceGetStatisticsOptions)

Récupère des statistiques relatives à la réplication pour le service de File d'attente. Elle est uniquement disponible sur le point de terminaison d'emplacement secondaire lorsque la réplication géographique redondante avec accès en lecture est activée pour le compte de stockage.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/get-queue-service-stats

listQueues(ServiceListQueuesOptions)

Retourne un itérateur itérable asynchrone pour répertorier toutes les files d’attente sous le compte spécifié.

.byPage() retourne un itérateur itérable asynchrone pour répertorier les files d’attente dans les pages.

Exemple utilisant la for await syntaxe :

let i = 1;
for await (const item of queueServiceClient.listQueues()) {
  console.log(`Queue${i}: ${item.name}`);
  i++;
}

Exemple utilisant iter.next() :

let i = 1;
let iterator = queueServiceClient.listQueues();
let item = await iterator.next();
while (!item.done) {
  console.log(`Queue${i}: ${item.value.name}`);
  i++;
  item = await iterator.next();
}

Exemple utilisant byPage() :

// passing optional maxPageSize in the page settings
let i = 1;
for await (const item2 of queueServiceClient.listQueues().byPage({ maxPageSize: 20 })) {
  if (item2.queueItems) {
    for (const queueItem of item2.queueItems) {
      console.log(`Queue${i}: ${queueItem.name}`);
      i++;
    }
  }
}

Exemple d’utilisation de la pagination avec un marqueur :

let i = 1;
let iterator = queueServiceClient.listQueues().byPage({ maxPageSize: 2 });
let item = (await iterator.next()).value;

// Prints 2 queue names
if (item.queueItems) {
  for (const queueItem of item.queueItems) {
    console.log(`Queue${i}: ${queueItem.name}`);
    i++;
  }
}
// Gets next marker
let marker = item.continuationToken;

// Passing next marker as continuationToken
iterator = queueServiceClient.listQueues().byPage({ continuationToken: marker, maxPageSize: 10 });
item = (await iterator.next()).value;

// Prints 10 queue names
if (item.queueItems) {
  for (const queueItem of item.queueItems) {
    console.log(`Queue${i}: ${queueItem.name}`);
    i++;
  }
}
setProperties(QueueServiceProperties, ServiceGetPropertiesOptions)

Définit les propriétés du point de terminaison du service file d’attente d’un compte de stockage, y compris les propriétés de Storage Analytics, les règles CORS (Cross-Origin Resource Sharing) et les paramètres de suppression réversible.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/set-queue-service-properties

Détails du constructeur

QueueServiceClient(string, Pipeline)

Crée une instance de QueueServiceClient.

new QueueServiceClient(url: string, pipeline: Pipeline)

Paramètres

url

string

Chaîne d’URL pointant vers le service de file d’attente Stockage Azure, telle que « https://myaccount.queue.core.windows.net". Vous pouvez ajouter une signature d’accès partagé si vous utilisez AnonymousCredential, par exemple «https://myaccount.queue.core.windows.net?sasString" ; ».

pipeline
Pipeline

Appelez newPipeline() pour créer un pipeline par défaut ou fournissez un pipeline personnalisé.

QueueServiceClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)

Crée une instance de QueueServiceClient.

new QueueServiceClient(url: string, credential?: StorageSharedKeyCredential | AnonymousCredential | TokenCredential, options?: StoragePipelineOptions)

Paramètres

url

string

Chaîne d’URL pointant vers le service de file d’attente Stockage Azure, telle que « https://myaccount.queue.core.windows.net". Vous pouvez ajouter une signature d’accès partagé si vous utilisez AnonymousCredential, par exemple «https://myaccount.queue.core.windows.net?sasString" ; ».

credential

StorageSharedKeyCredential | AnonymousCredential | TokenCredential

Par exemple, AnonymousCredential, StorageSharedKeyCredential ou toutes les informations d’identification du @azure/identity package pour authentifier les demandes adressées au service. Vous pouvez également fournir un objet qui implémente l’interface TokenCredential. S’il n’est pas spécifié, AnonymousCredential est utilisé.

options
StoragePipelineOptions

Options pour configurer le pipeline HTTP.

Exemple utilisant DefaultAzureCredential à partir de @azure/identity:

const account = "<account>";

const credential = new DefaultAzureCredential();

const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  credential
}

Exemple utilisant un nom/une clé de compte :

const account = "<account>";

const sharedKeyCredential = new StorageSharedKeyCredential(account, "<account key>");

const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  sharedKeyCredential,
  {
    retryOptions: { maxTries: 4 }, // Retry options
    telemetry: { value: "BasicSample/V11.0.0" } // Customized telemetry string
  }
);

Détails de la propriété héritée

accountName

accountName: string

Valeur de propriété

string

Hérité de StorageClient.accountName

url

Valeur de chaîne d’URL.

url: string

Valeur de propriété

string

Hérité de StorageClient.url

Détails de la méthode

createQueue(string, QueueCreateOptions)

Crée une file d’attente sous le compte spécifié.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/create-queue4

function createQueue(queueName: string, options?: QueueCreateOptions): Promise<QueueCreateResponse>

Paramètres

queueName

string

nom de la file d’attente à créer

options
QueueCreateOptions

Options de l’opération de création de file d’attente.

Retours

Données de réponse pour l’opération de création de file d’attente.

deleteQueue(string, QueueDeleteOptions)

Supprime définitivement la file d’attente spécifiée.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/delete-queue3

function deleteQueue(queueName: string, options?: QueueDeleteOptions): Promise<QueueDeleteResponse>

Paramètres

queueName

string

nom de la file d’attente à supprimer.

options
QueueDeleteOptions

Options de l’opération de suppression de file d’attente.

Retours

Données de réponse pour l’opération de suppression de file d’attente.

fromConnectionString(string, StoragePipelineOptions)

Crée une instance de QueueServiceClient.

static function fromConnectionString(connectionString: string, options?: StoragePipelineOptions): QueueServiceClient

Paramètres

connectionString

string

Chaîne de connexion de compte ou chaîne de connexion SAP d’un compte de stockage Azure. [ Remarque : la chaîne de connexion de compte ne peut être utilisée que dans NODE.JS runtime. ] Exemple de chaîne de connexion de compte -DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net Exemple de chaîne de connexion SAS - BlobEndpoint=https://myaccount.blob.core.windows.net/;QueueEndpoint=https://myaccount.queue.core.windows.net/;FileEndpoint=https://myaccount.file.core.windows.net/;TableEndpoint=https://myaccount.table.core.windows.net/;SharedAccessSignature=sasString

options
StoragePipelineOptions

Options pour configurer le pipeline HTTP.

Retours

Nouvel objet QueueServiceClient de la chaîne de connexion donnée.

generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Disponible uniquement pour QueueServiceClient construit avec des informations d’identification de clé partagée.

Génère un URI de signature d’accès partagé (SAS) de compte en fonction des propriétés et paramètres du client transmis. La signature SAS est signée par les informations d’identification de clé partagée du client.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/create-account-sas

function generateAccountSasUrl(expiresOn?: Date, permissions?: AccountSASPermissions, resourceTypes?: string, options?: ServiceGenerateAccountSasUrlOptions): string

Paramètres

expiresOn

Date

Optionnel. Heure à laquelle la signature d’accès partagé devient non valide. Par défaut, une heure plus tard s’il n’est pas spécifié.

permissions
AccountSASPermissions

Spécifie la liste des autorisations à associer à la sap.

resourceTypes

string

Spécifie les types de ressources associés à la signature d’accès partagé.

options
ServiceGenerateAccountSasUrlOptions

Paramètres facultatifs.

Retours

string

URI SAP de compte constitué de l’URI de la ressource représentée par ce client, suivi du jeton SAP généré.

getProperties(ServiceGetPropertiesOptions)

Obtient les propriétés du service file d’attente d’un compte de stockage, y compris les propriétés pour les règles Storage Analytics et CORS (Cross-Origin Resource Sharing).

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/get-queue-service-properties

function getProperties(options?: ServiceGetPropertiesOptions): Promise<ServiceGetPropertiesResponse>

Paramètres

options
ServiceGetPropertiesOptions

Options permettant d’obtenir l’opération des propriétés.

Retours

Données de réponse, y compris les propriétés du service de file d’attente.

getQueueClient(string)

Crée un objet QueueClient .

function getQueueClient(queueName: string): QueueClient

Paramètres

queueName

string

Retours

un nouveau QueueClient

Exemple d’utilisation :

const queueClient = queueServiceClient.getQueueClient("<new queue name>");
const createQueueResponse = await queueClient.create();

getStatistics(ServiceGetStatisticsOptions)

Récupère des statistiques relatives à la réplication pour le service de File d'attente. Elle est uniquement disponible sur le point de terminaison d'emplacement secondaire lorsque la réplication géographique redondante avec accès en lecture est activée pour le compte de stockage.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/get-queue-service-stats

function getStatistics(options?: ServiceGetStatisticsOptions): Promise<ServiceGetStatisticsResponse>

Paramètres

options
ServiceGetStatisticsOptions

Options pour obtenir l’opération de statistiques.

Retours

Données de réponse pour obtenir les statistiques de l’opération.

listQueues(ServiceListQueuesOptions)

Retourne un itérateur itérable asynchrone pour répertorier toutes les files d’attente sous le compte spécifié.

.byPage() retourne un itérateur itérable asynchrone pour répertorier les files d’attente dans les pages.

Exemple utilisant la for await syntaxe :

let i = 1;
for await (const item of queueServiceClient.listQueues()) {
  console.log(`Queue${i}: ${item.name}`);
  i++;
}

Exemple utilisant iter.next() :

let i = 1;
let iterator = queueServiceClient.listQueues();
let item = await iterator.next();
while (!item.done) {
  console.log(`Queue${i}: ${item.value.name}`);
  i++;
  item = await iterator.next();
}

Exemple utilisant byPage() :

// passing optional maxPageSize in the page settings
let i = 1;
for await (const item2 of queueServiceClient.listQueues().byPage({ maxPageSize: 20 })) {
  if (item2.queueItems) {
    for (const queueItem of item2.queueItems) {
      console.log(`Queue${i}: ${queueItem.name}`);
      i++;
    }
  }
}

Exemple d’utilisation de la pagination avec un marqueur :

let i = 1;
let iterator = queueServiceClient.listQueues().byPage({ maxPageSize: 2 });
let item = (await iterator.next()).value;

// Prints 2 queue names
if (item.queueItems) {
  for (const queueItem of item.queueItems) {
    console.log(`Queue${i}: ${queueItem.name}`);
    i++;
  }
}
// Gets next marker
let marker = item.continuationToken;

// Passing next marker as continuationToken
iterator = queueServiceClient.listQueues().byPage({ continuationToken: marker, maxPageSize: 10 });
item = (await iterator.next()).value;

// Prints 10 queue names
if (item.queueItems) {
  for (const queueItem of item.queueItems) {
    console.log(`Queue${i}: ${queueItem.name}`);
    i++;
  }
}
function listQueues(options?: ServiceListQueuesOptions): PagedAsyncIterableIterator<QueueItem, ServiceListQueuesSegmentResponse, PageSettings>

Paramètres

options
ServiceListQueuesOptions

Options permettant de répertorier les files d’attente.

Retours

AsyncIterableIterator qui prend en charge la pagination.

setProperties(QueueServiceProperties, ServiceGetPropertiesOptions)

Définit les propriétés du point de terminaison du service file d’attente d’un compte de stockage, y compris les propriétés de Storage Analytics, les règles CORS (Cross-Origin Resource Sharing) et les paramètres de suppression réversible.

Voir https://docs.microsoft.com/en-us/rest/api/storageservices/set-queue-service-properties

function setProperties(properties: QueueServiceProperties, options?: ServiceGetPropertiesOptions): Promise<ServiceSetPropertiesResponse>

Paramètres

options
ServiceGetPropertiesOptions

Options pour définir l’opération de propriétés.

Retours

Données de réponse pour l’opération Définir les propriétés.