Dela via

QueueServiceClient class

Paket:
@azure/storage-queue

En QueueServiceClient representerar en URL till Azure Storage Queue-tjänsten så att du kan ändra köer.

Extends

StorageClient

Konstruktorer

QueueServiceClient(string, Pipeline)

Skapar en instans av QueueServiceClient.
QueueServiceClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)

Skapar en instans av QueueServiceClient.

Ärvda egenskaper

accountName
url

URL-strängvärde.

Metoder

createQueue(string, QueueCreateOptions)

Skapar en ny kö under det angivna kontot.

Se https://free.blessedness.top/rest/api/storageservices/create-queue4
deleteQueue(string, QueueDeleteOptions)

Tar bort den angivna kön permanent.

Se https://free.blessedness.top/rest/api/storageservices/delete-queue3
fromConnectionString(string, StoragePipelineOptions)

Skapar en instans av QueueServiceClient.
generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Endast tillgängligt för QueueServiceClient som skapats med en delad nyckelautentiseringsuppgifter.

Genererar en SAS-URI (Signatur för delad åtkomst) baserat på klientegenskaperna och parametrarna som skickas in. SAS signeras av klientens autentiseringsuppgifter för delad nyckel.

Se https://free.blessedness.top/rest/api/storageservices/create-account-sas
generateSasStringToSign(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Endast tillgängligt för QueueServiceClient som skapats med en delad nyckelautentiseringsuppgifter.

Genererar sträng för att signera för ett konto med signatur för delad åtkomst (SAS) baserat på klientegenskaperna och parametrarna som skickas in. SAS signeras av klientens autentiseringsuppgifter för delad nyckel.

Se https://free.blessedness.top/rest/api/storageservices/create-account-sas
getProperties(ServiceGetPropertiesOptions)

Hämtar egenskaperna för ett lagringskontos kötjänst, inklusive egenskaper för lagringsanalys och CORS-regler (resursdelning mellan ursprung).

Se https://free.blessedness.top/rest/api/storageservices/get-queue-service-properties
getQueueClient(string)

Skapar ett QueueClient- objekt.
getStatistics(ServiceGetStatisticsOptions)

Hämtar statistik som rör replikering för kötjänsten. Den är endast tillgänglig på den sekundära platsslutpunkten när geo-redundant replikering med läsåtkomst är aktiverad för lagringskontot.

Se https://free.blessedness.top/rest/api/storageservices/get-queue-service-stats
listQueues(ServiceListQueuesOptions)

Returnerar en iterbar iterator som kan asynkronas för att visa en lista över alla köer under det angivna kontot.

.byPage() returnerar en iterator som kan itereras asynkront för att visa en lista över köerna på sidor.

Exempel med 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}`);
}

Exempel med 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());
}

Exempel med 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}`);
  }
}

Exempel med växling med en markör:

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)

Anger egenskaper för ett lagringskontos kötjänstslutpunkt, inklusive egenskaper för lagringsanalys, CORS-regler (resursdelning mellan ursprung) och inställningar för mjuk borttagning.

Se https://free.blessedness.top/rest/api/storageservices/set-queue-service-properties

Konstruktorinformation

QueueServiceClient(string, Pipeline)

Skapar en instans av QueueServiceClient.

new QueueServiceClient(url: string, pipeline: Pipeline)

Parametrar

url

string

En URL-sträng som pekar på Azure Storage-kötjänsten, till exempel "https://myaccount.queue.core.windows.net". Du kan lägga till en SAS om du använder AnonymousCredential, till exempel "https://myaccount.queue.core.windows.net?sasString".

pipeline
Pipeline

Anropa newPipeline() för att skapa en standardpipeline eller ange en anpassad pipeline.

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

Skapar en instans av QueueServiceClient.

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

Parametrar

url

string

En URL-sträng som pekar på Azure Storage-kötjänsten, till exempel "https://myaccount.queue.core.windows.net". Du kan lägga till en SAS om du använder AnonymousCredential, till exempel "https://myaccount.queue.core.windows.net?sasString".

credential

StorageSharedKeyCredential | AnonymousCredential | TokenCredential

Till exempel AnonymousCredential, StorageSharedKeyCredential eller eventuella autentiseringsuppgifter från @azure/identity-paketet för att autentisera begäranden till tjänsten. Du kan också ange ett objekt som implementerar TokenCredential-gränssnittet. Om det inte anges används AnonymousCredential.

options
StoragePipelineOptions

Alternativ för att konfigurera HTTP-pipelinen.

Exempel med defaultAzureCredential från @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,
);

Exempel med ett kontonamn/nyckel:

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

Information om ärvda egenskaper

accountName 

accountName: string

Egenskapsvärde

string

ärvd från StorageClient.accountName

url

URL-strängvärde.

url: string

Egenskapsvärde

string

ärvd från StorageClient.url

Metodinformation

createQueue(string, QueueCreateOptions)

Skapar en ny kö under det angivna kontot.

Se https://free.blessedness.top/rest/api/storageservices/create-queue4

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

Parametrar

queueName

string

namnet på kön som ska skapas

options
QueueCreateOptions

Alternativ för att skapa köåtgärd.

Returer

Promise<QueueCreateResponse>

Svarsdata för åtgärden Skapa kö.

deleteQueue(string, QueueDeleteOptions)

Tar bort den angivna kön permanent.

Se https://free.blessedness.top/rest/api/storageservices/delete-queue3

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

Parametrar

queueName

string

namnet på kön som ska tas bort.

options
QueueDeleteOptions

Alternativ för borttagning av kö.

Returer

Promise<QueueDeleteResponse>

Svarsdata för borttagningsåtgärden Kö.

fromConnectionString(string, StoragePipelineOptions)

Skapar en instans av QueueServiceClient.

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

Parametrar

connectionString

string

Kontoanslutningssträng eller en SAS-anslutningssträng för ett Azure Storage-konto. [ Obs! Kontoanslutningssträngen kan bara användas i NODE.JS körning. ] Exempel på kontoanslutningssträng – DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net EXEMPEL på SAS-anslutningssträng – 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

Alternativ för att konfigurera HTTP-pipelinen.

Returer

QueueServiceClient

Ett nytt QueueServiceClient-objekt från den angivna anslutningssträngen.

generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Endast tillgängligt för QueueServiceClient som skapats med en delad nyckelautentiseringsuppgifter.

Genererar en SAS-URI (Signatur för delad åtkomst) baserat på klientegenskaperna och parametrarna som skickas in. SAS signeras av klientens autentiseringsuppgifter för delad nyckel.

Se https://free.blessedness.top/rest/api/storageservices/create-account-sas

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

Parametrar

expiresOn

Date

Optional. Den tidpunkt då signaturen för delad åtkomst blir ogiltig. Standardvärdet är en timme senare om det inte anges.

permissions
AccountSASPermissions

Anger listan över behörigheter som ska associeras med SAS.

resourceTypes

string

Anger de resurstyper som är associerade med signaturen för delad åtkomst.

options
ServiceGenerateAccountSasUrlOptions

Valfria parametrar.

Returer

string

En SAS-URI för kontot som består av URI:n för den resurs som representeras av den här klienten, följt av den genererade SAS-token.

generateSasStringToSign(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)

Endast tillgängligt för QueueServiceClient som skapats med en delad nyckelautentiseringsuppgifter.

Genererar sträng för att signera för ett konto med signatur för delad åtkomst (SAS) baserat på klientegenskaperna och parametrarna som skickas in. SAS signeras av klientens autentiseringsuppgifter för delad nyckel.

Se https://free.blessedness.top/rest/api/storageservices/create-account-sas

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

Parametrar

expiresOn

Date

Optional. Den tidpunkt då signaturen för delad åtkomst blir ogiltig. Standardvärdet är en timme senare om det inte anges.

permissions
AccountSASPermissions

Anger listan över behörigheter som ska associeras med SAS.

resourceTypes

string

Anger de resurstyper som är associerade med signaturen för delad åtkomst.

options
ServiceGenerateAccountSasUrlOptions

Valfria parametrar.

Returer

string

En SAS-URI för kontot som består av URI:n för den resurs som representeras av den här klienten, följt av den genererade SAS-token.

getProperties(ServiceGetPropertiesOptions)

Hämtar egenskaperna för ett lagringskontos kötjänst, inklusive egenskaper för lagringsanalys och CORS-regler (resursdelning mellan ursprung).

Se https://free.blessedness.top/rest/api/storageservices/get-queue-service-properties

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

Parametrar

options
ServiceGetPropertiesOptions

Alternativ för att hämta egenskapsåtgärden.

Returer

Promise<ServiceGetPropertiesResponse>

Svarsdata inklusive kötjänstens egenskaper.

getQueueClient(string)

Skapar ett QueueClient- objekt.

function getQueueClient(queueName: string): QueueClient

Parametrar

queueName

string

Returer

QueueClient

en ny QueueClient

Exempel på användning:

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)

Hämtar statistik som rör replikering för kötjänsten. Den är endast tillgänglig på den sekundära platsslutpunkten när geo-redundant replikering med läsåtkomst är aktiverad för lagringskontot.

Se https://free.blessedness.top/rest/api/storageservices/get-queue-service-stats

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

Parametrar

options
ServiceGetStatisticsOptions

Alternativ för att hämta statistikåtgärden.

Returer

Promise<ServiceGetStatisticsResponse>

Svarsdata för att hämta statistik åtgärden.

listQueues(ServiceListQueuesOptions)

Returnerar en iterbar iterator som kan asynkronas för att visa en lista över alla köer under det angivna kontot.

.byPage() returnerar en iterator som kan itereras asynkront för att visa en lista över köerna på sidor.

Exempel med 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}`);
}

Exempel med 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());
}

Exempel med 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}`);
  }
}

Exempel med växling med en markör:

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>

Parametrar

options
ServiceListQueuesOptions

Alternativ för att lista köåtgärder.

Returer

PagedAsyncIterableIterator<QueueItem, ServiceListQueuesSegmentResponse, PageSettings>

En asyncIterableIterator som stöder växling.

setProperties(QueueServiceProperties, ServiceGetPropertiesOptions)

Anger egenskaper för ett lagringskontos kötjänstslutpunkt, inklusive egenskaper för lagringsanalys, CORS-regler (resursdelning mellan ursprung) och inställningar för mjuk borttagning.

Se https://free.blessedness.top/rest/api/storageservices/set-queue-service-properties

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

Parametrar

properties
QueueServiceProperties
options
ServiceGetPropertiesOptions

Alternativ för att ange egenskapsåtgärd.

Returer

Promise<ServiceSetPropertiesResponse>

Svarsdata för åtgärden Ange egenskaper.