Delen via

QueueServiceClient class

Pakket:
@azure/storage-queue

Een QueueServiceClient vertegenwoordigt een URL naar de Azure Storage Queue-service waarmee u wachtrijen kunt bewerken.

Uitbreiding
StorageClient

Constructors

QueueServiceClient(string, Pipeline)

Hiermee maakt u een exemplaar van QueueServiceClient.
QueueServiceClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)

Hiermee maakt u een exemplaar van QueueServiceClient.

Eigenschappen

accountName
url

URL-tekenreekswaarde.

Methoden

createQueue(string, QueueCreateOptions)

Hiermee maakt u een nieuwe wachtrij onder het opgegeven account.
deleteQueue(string, QueueDeleteOptions)

Hiermee verwijdert u de opgegeven wachtrij permanent.
fromConnectionString(string, StoragePipelineOptions)

Hiermee maakt u een exemplaar van QueueServiceClient.
generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Alleen beschikbaar voor QueueServiceClient die is samengesteld met een gedeelde sleutelreferentie. Hiermee wordt een SAS-URI (Shared Access Signature) gegenereerd op basis van de clienteigenschappen en parameters die zijn doorgegeven. De SAS wordt ondertekend door de gedeelde sleutelreferentie van de client.
getProperties(ServiceGetPropertiesOptions)

Hiermee haalt u de eigenschappen op van de wachtrijservice van een opslagaccount, inclusief eigenschappen voor regels voor Opslaganalyse en CORS (Cross-Origin Resource Sharing).
getQueueClient(string)

Hiermee maakt u een <xref:QueueClient>-object.
getStatistics(ServiceGetStatisticsOptions)

Hiermee worden statistieken opgehaald die betrekking hebben op replicatie voor de Queue-service. Het is alleen beschikbaar op het eindpunt van de secundaire locatie wanneer geografisch redundante replicatie met leestoegang is ingeschakeld voor het opslagaccount.
listQueues(ServiceListQueuesOptions)

Retourneert een asynchrone iterator om alle wachtrijen onder het opgegeven account weer te geven. .byPage() retourneert een asynchrone iterator om de wachtrijen op pagina's weer te geven.

Voorbeeld van for await syntaxis:

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

Voorbeeld van iter.next():

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

Voorbeeld van 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++;
    }
  }
}

Voorbeeld van het gebruik van paging met een markering:

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)

Hiermee stelt u eigenschappen in voor het service-eindpunt queue van een opslagaccount, waaronder eigenschappen voor Opslaganalyse, CORS-regels (Cross-Origin Resource Sharing) en instellingen voor voorlopig verwijderen.

Constructordetails

QueueServiceClient(string, Pipeline)

Hiermee maakt u een exemplaar van QueueServiceClient.

new QueueServiceClient(url: string, pipeline: Pipeline)

Parameters

url

string

Een URL-tekenreeks die verwijst naar de Azure Storage-wachtrijservice, zoals 'https://myaccount.queue.core.windows.net". U kunt een SAS toevoegen als u AnonymousCredential gebruikt, zoals 'https://myaccount.queue.core.windows.net?sasString".

pipeline
Pipeline

Roep newPipeline() aan om een standaardpijplijn te maken of geef een aangepaste pijplijn op.

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

Hiermee maakt u een exemplaar van QueueServiceClient.

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

Parameters

url

string

Een URL-tekenreeks die verwijst naar de Azure Storage-wachtrijservice, zoals 'https://myaccount.queue.core.windows.net". U kunt een SAS toevoegen als u AnonymousCredential gebruikt, zoals 'https://myaccount.queue.core.windows.net?sasString".

credential

StorageSharedKeyCredential | AnonymousCredential | TokenCredential

Zoals AnonymousCredential, StorageSharedKeyCredential of referenties van het @azure/identity-pakket om aanvragen voor de service te verifiëren. U kunt ook een object opgeven waarmee de TokenCredential-interface wordt geïmplementeerd. Als dit niet is opgegeven, wordt AnonymousCredential gebruikt.

options
StoragePipelineOptions

Opties voor het configureren van de HTTP-pijplijn.

Voorbeeld van het gebruik van DefaultAzureCredential uit @azure/identity:

const account = "<account>";

const credential = new DefaultAzureCredential();

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

Voorbeeld van een accountnaam/-sleutel:

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
  }
);

Eigenschapdetails

accountName 

accountName: string

Waarde van eigenschap

string

url

URL-tekenreekswaarde.

url: string

Waarde van eigenschap

string

Methodedetails

createQueue(string, QueueCreateOptions)

Hiermee maakt u een nieuwe wachtrij onder het opgegeven account.

function createQueue(queueName: string, options?: QueueCreateOptions)

Parameters

queueName

string

naam van de wachtrij die moet worden gemaakt

options
QueueCreateOptions

Opties voor het maken van wachtrijbewerkingen.

Retouren

Promise<QueueCreateResponse>

Antwoordgegevens voor de bewerking Wachtrij maken.

deleteQueue(string, QueueDeleteOptions)

Hiermee verwijdert u de opgegeven wachtrij permanent.

function deleteQueue(queueName: string, options?: QueueDeleteOptions)

Parameters

queueName

string

naam van de wachtrij die u wilt verwijderen.

options
QueueDeleteOptions

Opties voor het verwijderen van wachtrijbewerkingen.

Retouren

Promise<QueueDeleteResponse>

Antwoordgegevens voor de verwijderbewerking wachtrij.

fromConnectionString(string, StoragePipelineOptions)

Hiermee maakt u een exemplaar van QueueServiceClient.

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

Parameters

connectionString

string

Verbindingsreeks voor het account of een SAS-verbindingsreeks van een Azure-opslagaccount. [ Opmerking: de verbindingsreeks van het account kan alleen worden gebruikt in NODE.JS runtime. ] Voorbeeld van accountverbindingsreeks - voorbeeld van DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net SAS-verbindingsreeks - 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

Opties voor het configureren van de HTTP-pijplijn.

Retouren

QueueServiceClient

Een nieuw QueueServiceClient-object uit de opgegeven verbindingsreeks.

generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Alleen beschikbaar voor QueueServiceClient die is samengesteld met een gedeelde sleutelreferentie. Hiermee wordt een SAS-URI (Shared Access Signature) gegenereerd op basis van de clienteigenschappen en parameters die zijn doorgegeven. De SAS wordt ondertekend door de gedeelde sleutelreferentie van de client.

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

Parameters

expiresOn

Date

Facultatief. Het tijdstip waarop de handtekening voor gedeelde toegang ongeldig wordt. Standaard een uur later als dit niet is opgegeven.

permissions
AccountSASPermissions

Hiermee geeft u de lijst met machtigingen die aan de SAS moeten worden gekoppeld.

resourceTypes

string

Hiermee geeft u de resourcetypen op die zijn gekoppeld aan de handtekening voor gedeelde toegang.

options
ServiceGenerateAccountSasUrlOptions

Optionele parameters.

Retouren

string

Een account-SAS-URI die bestaat uit de URI voor de resource die wordt vertegenwoordigd door deze client, gevolgd door het gegenereerde SAS-token.

getProperties(ServiceGetPropertiesOptions)

Hiermee haalt u de eigenschappen op van de wachtrijservice van een opslagaccount, inclusief eigenschappen voor regels voor Opslaganalyse en CORS (Cross-Origin Resource Sharing).

function getProperties(options?: ServiceGetPropertiesOptions)

Parameters

options
ServiceGetPropertiesOptions

Opties voor het ophalen van de eigenschappenbewerking.

Retouren

Promise<ServiceGetPropertiesResponse>

Antwoordgegevens, inclusief de eigenschappen van de wachtrijservice.

getQueueClient(string)

Hiermee maakt u een <xref:QueueClient>-object.

function getQueueClient(queueName: string)

Parameters

queueName

string

Retouren

QueueClient

een nieuwe QueueClient

Voorbeeldgebruik:

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

getStatistics(ServiceGetStatisticsOptions)

Hiermee worden statistieken opgehaald die betrekking hebben op replicatie voor de Queue-service. Het is alleen beschikbaar op het eindpunt van de secundaire locatie wanneer geografisch redundante replicatie met leestoegang is ingeschakeld voor het opslagaccount.

function getStatistics(options?: ServiceGetStatisticsOptions)

Parameters

options
ServiceGetStatisticsOptions

Opties voor het ophalen van statistiekenbewerkingen.

Retouren

Promise<ServiceGetStatisticsResponse>

Antwoordgegevens voor het ophalen van statistieken over de bewerking.

listQueues(ServiceListQueuesOptions)

Retourneert een asynchrone iterator om alle wachtrijen onder het opgegeven account weer te geven. .byPage() retourneert een asynchrone iterator om de wachtrijen op pagina's weer te geven.

Voorbeeld van for await syntaxis:

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

Voorbeeld van iter.next():

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

Voorbeeld van 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++;
    }
  }
}

Voorbeeld van het gebruik van paging met een markering:

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)

Parameters

options
ServiceListQueuesOptions

Opties voor het weergeven van wachtrijen.

Retouren

PagedAsyncIterableIterator<QueueItem, ServiceListQueuesSegmentResponse>

Een asyncIterableIterator die paging ondersteunt.

setProperties(QueueServiceProperties, ServiceGetPropertiesOptions)

Hiermee stelt u eigenschappen in voor het service-eindpunt queue van een opslagaccount, waaronder eigenschappen voor Opslaganalyse, CORS-regels (Cross-Origin Resource Sharing) en instellingen voor voorlopig verwijderen.

function setProperties(properties: QueueServiceProperties, options?: ServiceGetPropertiesOptions)

Parameters

properties
QueueServiceProperties
options
ServiceGetPropertiesOptions

Opties voor het instellen van de eigenschappenbewerking.

Retouren

Promise<ServiceSetPropertiesResponse>

Antwoordgegevens voor de bewerking Eigenschappen instellen.