Freigeben über

QueueServiceClient class

Paket:
@azure/storage-queue

Ein QueueServiceClient stellt eine URL zum Azure Storage Queue-Dienst dar, mit dem Sie Warteschlangen bearbeiten können.

Extends

StorageClient

Konstruktoren

QueueServiceClient(string, Pipeline)

Erstellt eine Instanz von QueueServiceClient.
QueueServiceClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)

Erstellt eine Instanz von QueueServiceClient.

Geerbte Eigenschaften

accountName
url

URL-Zeichenfolgenwert.

Methoden

createQueue(string, QueueCreateOptions)

Erstellt eine neue Warteschlange unter dem angegebenen Konto.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/create-queue4.
deleteQueue(string, QueueDeleteOptions)

Löscht die angegebene Warteschlange dauerhaft.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/delete-queue3.
fromConnectionString(string, StoragePipelineOptions)

Erstellt eine Instanz von QueueServiceClient.
generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Nur für QueueServiceClient verfügbar, der mit freigegebenen Schlüsselanmeldeinformationen erstellt wurde.

Generiert einen SAS-URI (Shared Access Signature) basierend auf den Clienteigenschaften und Parametern, die übergeben werden. Die SAS wird von den freigegebenen Schlüsselanmeldeinformationen des Clients signiert.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/create-account-sas.
generateSasStringToSign(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Nur für QueueServiceClient verfügbar, der mit freigegebenen Schlüsselanmeldeinformationen erstellt wurde.

Generiert eine Zeichenfolge zum Signieren für einen SAS-URI (Shared Access Signature), der auf den Clienteigenschaften und Parametern basiert, die übergeben werden. Die SAS wird von den freigegebenen Schlüsselanmeldeinformationen des Clients signiert.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/create-account-sas.
getProperties(ServiceGetPropertiesOptions)

Ruft die Eigenschaften des Warteschlangendiensts eines Speicherkontos ab, einschließlich Eigenschaften für Speicheranalyse- und CORS-Regeln (Cross-Origin Resource Sharing).

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/get-queue-service-properties.
getQueueClient(string)

Erstellt ein QueueClient- -Objekt.
getStatistics(ServiceGetStatisticsOptions)

Ruft Statistiken zur Replikation für den Warteschlangendienst ab. Sie ist nur für den sekundären Standortendpunkt verfügbar, wenn die georedundante Replikation mit Lesezugriff für das Speicherkonto aktiviert ist.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/get-queue-service-stats.
listQueues(ServiceListQueuesOptions)

Gibt einen asynchronen iterierbaren Iterator zurück, um alle Warteschlangen unter dem angegebenen Konto auflisten zu können.

.byPage() gibt einen asynchronen iterablen Iterator zurück, um die Warteschlangen auf Seiten auflisten zu können.

Beispiel mit for await Syntax:

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

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

Beispiel für die Verwendung von iter.next():

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

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

Beispiel für die Verwendung von byPage():

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

let i = 1;
for await (const page of queueServiceClient.listQueues().byPage({ maxPageSize: 20 })) {
  for (const item of page.queueItems || []) {
    console.log(`Queue${i++}: ${item.name}`);
  }
}

Beispiel für das Paging mit einer Markierung:

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

let i = 1;
let iterator = queueServiceClient.listQueues().byPage({ maxPageSize: 2 });
let response = (await iterator.next()).value;
// Prints 2 queues
if (response.queueItems) {
  for (const item of response.queueItems) {
    console.log(`Queue${i++}: ${item.name}`);
  }
}
// Gets next marker
let marker = response.continuationToken;
// Passing next marker as continuationToken
iterator = queueServiceClient.listQueues().byPage({ continuationToken: marker, maxPageSize: 10 });
response = (await iterator.next()).value;
// Prints 10 queues
if (response.queueItems) {
  for (const item of response.queueItems) {
    console.log(`Queue${i++}: ${item.name}`);
  }
}
setProperties(QueueServiceProperties, ServiceGetPropertiesOptions)

Legt Eigenschaften für den Warteschlangendienstendpunkt eines Speicherkontos fest, einschließlich Eigenschaften für Speicheranalyse, CORS -Regeln (Cross-Origin Resource Sharing) und Einstellungen für vorläufiges Löschen.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/set-queue-service-properties.

Details zum Konstruktor

QueueServiceClient(string, Pipeline)

Erstellt eine Instanz von QueueServiceClient.

new QueueServiceClient(url: string, pipeline: Pipeline)

Parameter

url

string

Eine URL-Zeichenfolge, die auf den Azure Storage-Warteschlangendienst verweist, z. B. "https://myaccount.queue.core.windows.net". Sie können eine SAS anfügen, wenn Anonyme Anmeldeinformationen verwendet werden, z. B. "https://myaccount.queue.core.windows.net?sasString".

pipeline
Pipeline

Rufen Sie newPipeline() auf, um eine Standardpipeline zu erstellen oder eine angepasste Pipeline bereitzustellen.

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

Erstellt eine Instanz von QueueServiceClient.

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

Parameter

url

string

Eine URL-Zeichenfolge, die auf den Azure Storage-Warteschlangendienst verweist, z. B. "https://myaccount.queue.core.windows.net". Sie können eine SAS anfügen, wenn Anonyme Anmeldeinformationen verwendet werden, z. B. "https://myaccount.queue.core.windows.net?sasString".

credential

StorageSharedKeyCredential | AnonymousCredential | TokenCredential

Wie anonyme Anmeldeinformationen, StorageSharedKeyCredential oder anmeldeinformationen aus dem @azure/identity-Paket zum Authentifizieren von Anforderungen an den Dienst. Sie können auch ein Objekt bereitstellen, das die TokenCredential-Schnittstelle implementiert. Wenn nicht angegeben, wird AnonymousCredential verwendet.

options
StoragePipelineOptions

Optionen zum Konfigurieren der HTTP-Pipeline.

Beispiel für die Verwendung von DefaultAzureCredential aus @azure/identity:

import { DefaultAzureCredential } from "@azure/identity";
import { QueueServiceClient } from "@azure/storage-queue";

const account = "<account>";
const credential = new DefaultAzureCredential();

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

Beispiel für die Verwendung eines Kontonamens/Schlüssels:

import { StorageSharedKeyCredential, QueueServiceClient } from "@azure/storage-queue";

// Enter your storage account name and shared key
const account = "<account>";
const accountKey = "<accountkey>";

// Use StorageSharedKeyCredential with storage account and account key
// StorageSharedKeyCredential is only available in Node.js runtime, not in browsers
const sharedKeyCredential = new StorageSharedKeyCredential(account, accountKey);

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

Geerbte Eigenschaftsdetails

accountName 

accountName: string

Eigenschaftswert

string

geerbt von StorageClient.accountName

url

URL-Zeichenfolgenwert.

url: string

Eigenschaftswert

string

geerbt von StorageClient.url

Details zur Methode

createQueue(string, QueueCreateOptions)

Erstellt eine neue Warteschlange unter dem angegebenen Konto.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/create-queue4.

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

Parameter

queueName

string

Name der zu erstellenden Warteschlange

options
QueueCreateOptions

Optionen für den Erstellungsvorgang der Warteschlange.

Gibt zurück

Promise<QueueCreateResponse>

Antwortdaten für den Warteschlangenerstellungsvorgang.

deleteQueue(string, QueueDeleteOptions)

Löscht die angegebene Warteschlange dauerhaft.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/delete-queue3.

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

Parameter

queueName

string

Name der zu löschenden Warteschlange.

options
QueueDeleteOptions

Optionen zum Löschvorgang in der Warteschlange.

Gibt zurück

Promise<QueueDeleteResponse>

Antwortdaten für den Löschvorgang der Warteschlange.

fromConnectionString(string, StoragePipelineOptions)

Erstellt eine Instanz von QueueServiceClient.

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

Parameter

connectionString

string

Kontoverbindungszeichenfolge oder SAS-Verbindungszeichenfolge eines Azure-Speicherkontos. [ Hinweis : Kontoverbindungszeichenfolge kann nur in NODE.JS Laufzeit verwendet werden. ] Beispiel für kontoverbindungszeichenfolge - beispiel für DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net SAS-Verbindungszeichenfolge - 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

Optionen zum Konfigurieren der HTTP-Pipeline.

Gibt zurück

QueueServiceClient

Ein neues QueueServiceClient-Objekt aus der angegebenen Verbindungszeichenfolge.

generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Nur für QueueServiceClient verfügbar, der mit freigegebenen Schlüsselanmeldeinformationen erstellt wurde.

Generiert einen SAS-URI (Shared Access Signature) basierend auf den Clienteigenschaften und Parametern, die übergeben werden. Die SAS wird von den freigegebenen Schlüsselanmeldeinformationen des Clients signiert.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/create-account-sas.

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

Parameter

expiresOn

Date

Optional. Der Zeitpunkt, zu dem die Signatur des freigegebenen Zugriffs ungültig wird. Wenn nicht angegeben, wird die Standardeinstellung auf eine Stunde später festgelegt.

permissions
AccountSASPermissions

Gibt die Liste der Berechtigungen an, die der SAS zugeordnet werden sollen.

resourceTypes

string

Gibt die Ressourcentypen an, die der Gemeinsamen Zugriffssignatur zugeordnet sind.

options
ServiceGenerateAccountSasUrlOptions

Optionale Parameter.

Gibt zurück

string

Ein SAS-Konto-URI, der aus dem URI für die Ressource besteht, die von diesem Client dargestellt wird, gefolgt von dem generierten SAS-Token.

generateSasStringToSign(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Nur für QueueServiceClient verfügbar, der mit freigegebenen Schlüsselanmeldeinformationen erstellt wurde.

Generiert eine Zeichenfolge zum Signieren für einen SAS-URI (Shared Access Signature), der auf den Clienteigenschaften und Parametern basiert, die übergeben werden. Die SAS wird von den freigegebenen Schlüsselanmeldeinformationen des Clients signiert.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/create-account-sas.

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

Parameter

expiresOn

Date

Optional. Der Zeitpunkt, zu dem die Signatur des freigegebenen Zugriffs ungültig wird. Wenn nicht angegeben, wird die Standardeinstellung auf eine Stunde später festgelegt.

permissions
AccountSASPermissions

Gibt die Liste der Berechtigungen an, die der SAS zugeordnet werden sollen.

resourceTypes

string

Gibt die Ressourcentypen an, die der Gemeinsamen Zugriffssignatur zugeordnet sind.

options
ServiceGenerateAccountSasUrlOptions

Optionale Parameter.

Gibt zurück

string

Ein SAS-Konto-URI, der aus dem URI für die Ressource besteht, die von diesem Client dargestellt wird, gefolgt von dem generierten SAS-Token.

getProperties(ServiceGetPropertiesOptions)

Ruft die Eigenschaften des Warteschlangendiensts eines Speicherkontos ab, einschließlich Eigenschaften für Speicheranalyse- und CORS-Regeln (Cross-Origin Resource Sharing).

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/get-queue-service-properties.

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

Parameter

options
ServiceGetPropertiesOptions

Optionen zum Abrufen des Eigenschaftenvorgangs.

Gibt zurück

Promise<ServiceGetPropertiesResponse>

Antwortdaten, einschließlich der Warteschlangendiensteigenschaften.

getQueueClient(string)

Erstellt ein QueueClient- -Objekt.

function getQueueClient(queueName: string): QueueClient

Parameter

queueName

string

Gibt zurück

QueueClient

ein neuer QueueClient

Beispielverwendung:

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

const queueName = "<valid queue name>";
const queueClient = queueServiceClient.getQueueClient(queueName);
const createQueueResponse = await queueClient.create();
console.log(
  `Created queue ${queueName} successfully, service assigned request Id: ${createQueueResponse.requestId}`,
);

getStatistics(ServiceGetStatisticsOptions)

Ruft Statistiken zur Replikation für den Warteschlangendienst ab. Sie ist nur für den sekundären Standortendpunkt verfügbar, wenn die georedundante Replikation mit Lesezugriff für das Speicherkonto aktiviert ist.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/get-queue-service-stats.

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

Parameter

options
ServiceGetStatisticsOptions

Optionen zum Abrufen des Statistikvorgangs.

Gibt zurück

Promise<ServiceGetStatisticsResponse>

Antwortdaten zum Abrufen von Statistiken für den Vorgang.

listQueues(ServiceListQueuesOptions)

Gibt einen asynchronen iterierbaren Iterator zurück, um alle Warteschlangen unter dem angegebenen Konto auflisten zu können.

.byPage() gibt einen asynchronen iterablen Iterator zurück, um die Warteschlangen auf Seiten auflisten zu können.

Beispiel mit for await Syntax:

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

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

Beispiel für die Verwendung von iter.next():

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

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

Beispiel für die Verwendung von byPage():

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

let i = 1;
for await (const page of queueServiceClient.listQueues().byPage({ maxPageSize: 20 })) {
  for (const item of page.queueItems || []) {
    console.log(`Queue${i++}: ${item.name}`);
  }
}

Beispiel für das Paging mit einer Markierung:

import { QueueServiceClient } from "@azure/storage-queue";
import { DefaultAzureCredential } from "@azure/identity";

const account = "<account>";
const queueServiceClient = new QueueServiceClient(
  `https://${account}.queue.core.windows.net`,
  new DefaultAzureCredential(),
);

let i = 1;
let iterator = queueServiceClient.listQueues().byPage({ maxPageSize: 2 });
let response = (await iterator.next()).value;
// Prints 2 queues
if (response.queueItems) {
  for (const item of response.queueItems) {
    console.log(`Queue${i++}: ${item.name}`);
  }
}
// Gets next marker
let marker = response.continuationToken;
// Passing next marker as continuationToken
iterator = queueServiceClient.listQueues().byPage({ continuationToken: marker, maxPageSize: 10 });
response = (await iterator.next()).value;
// Prints 10 queues
if (response.queueItems) {
  for (const item of response.queueItems) {
    console.log(`Queue${i++}: ${item.name}`);
  }
}

function listQueues(options?: ServiceListQueuesOptions): PagedAsyncIterableIterator<QueueItem, ServiceListQueuesSegmentResponse, PageSettings>

Parameter

options
ServiceListQueuesOptions

Optionen zum Auflisten des Warteschlangenvorgangs.

Gibt zurück

PagedAsyncIterableIterator<QueueItem, ServiceListQueuesSegmentResponse, PageSettings>

Ein asyncIterableIterator, der paging unterstützt.

setProperties(QueueServiceProperties, ServiceGetPropertiesOptions)

Legt Eigenschaften für den Warteschlangendienstendpunkt eines Speicherkontos fest, einschließlich Eigenschaften für Speicheranalyse, CORS -Regeln (Cross-Origin Resource Sharing) und Einstellungen für vorläufiges Löschen.

Siehe https://v4.hkg1.meaqua.org/rest/api/storageservices/set-queue-service-properties.

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

Parameter

properties
QueueServiceProperties
options
ServiceGetPropertiesOptions

Optionen zum Festlegen des Eigenschaftenvorgangs.

Gibt zurück

Promise<ServiceSetPropertiesResponse>

Antwortdaten für den Vorgang "Eigenschaften festlegen".