BlobChangeFeedClient class

Csomag:: @azure/storage-blob-changefeed

BlobChangeFeedClient.

Lásd: https://docs.microsoft.com/en-us/azure/storage/blobs/storage-blob-change-feed?tabs=azure-portal

Konstruktorok

BlobChangeFeedClient(string, Pipeline)	Létrehozza a BlobChangeFeedClient egy példányát.
BlobChangeFeedClient(string, StorageSharedKeyCredential \| AnonymousCredential \| TokenCredential, StoragePipelineOptions, BlobChangeFeedClientOptions)	Létrehozza a BlobChangeFeedClient egy példányát.

Metódusok

fromConnectionString(string, StoragePipelineOptions, BlobChangeFeedClientOptions)

Létrehozza a BlobChangeFeedClient egy példányát a kapcsolati sztringből.

listChanges(BlobChangeFeedListChangesOptions)

Egy aszinkron iterátort ad vissza a megadott fiók összes változáscsatorna-eseményének listázásához.

A .byPage() egy aszinkron iterátort ad vissza a lapok változáscsatorna-eseményeinek listázásához.

Példa for await szintaxis használatára:

let i = 1;
for await (const event of blobChangeFeedClient.listChanges()) {
  console.log(`Event ${i++}, type: ${event.eventType}`);
}

Példa a iter.next() használatára:

let i = 1;
const iter = blobChangeFeedClient.listChanges();
let eventItem = await iter.next();
while (!eventItem.done) {
  console.log(`Event ${i++}, type: ${eventItem.eventType}`);
  eventItem = await iter.next();
}

Példa a byPage() használatára:

// passing optional maxPageSize in the page settings
let i = 1;
for await (const eventPage of blobChangeFeedClient.listChanges().byPage({ maxPageSize: 20 })) {
  if (eventPage.events) {
    for (const event of eventPage.events) {
      console.log(`Event ${i++}, type: ${event.eventType}`);
    }
  }
}

Példa jelölővel ellátott lapozásra:

let i = 1;
let iterator = blobChangeFeedClient.listChanges().byPage({ maxPageSize: 2 });
let eventPage = (await iterator.next()).value;

if (eventPage.events) {
  for (const container of eventPage.events) {
    console.log(`Event ${i++}, type: ${event.eventType}`);
  }
}

// Gets next marker
let marker = eventPage.continuationToken;
// Passing next marker as continuationToken
iterator = blobChangeFeedClient
  .listChanges()
  .byPage({ continuationToken: marker, maxPageSize: 10 });
eventPage = (await iterator.next()).value;

if (eventPage.events) {
  for (const container of eventPage.events) {
     console.log(`Event ${i++}, type: ${event.eventType}`);
  }
}

Konstruktor adatai

BlobChangeFeedClient(string, Pipeline)

Létrehozza a BlobChangeFeedClient egy példányát.

new BlobChangeFeedClient(url: string, pipeline: Pipeline)

Paraméterek

url: string

Egy Azure Storage-blobszolgáltatásra mutató ügyfélsztring, például "https://myaccount.blob.core.windows.net". Az SAS hozzáfűzhető, ha AnonymousCredentialt használ, például "https://myaccount.blob.core.windows.net?sasString".

pipeline: Pipeline

A newPipeline() hívása egy alapértelmezett folyamat létrehozásához vagy egy testreszabott folyamat megadásához.

BlobChangeFeedClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions, BlobChangeFeedClientOptions)

Létrehozza a BlobChangeFeedClient egy példányát.

new BlobChangeFeedClient(url: string, credential?: StorageSharedKeyCredential | AnonymousCredential | TokenCredential, options?: StoragePipelineOptions, changeFeedClientOptions?: BlobChangeFeedClientOptions)

Paraméterek

url: string

credential: StorageSharedKeyCredential | AnonymousCredential | TokenCredential

Ilyen például az AnonymousCredential, a StorageSharedKeyCredential vagy a @azure/identity csomag bármely hitelesítő adata a szolgáltatás felé irányuló kérések hitelesítéséhez. Olyan objektumot is megadhat, amely implementálja a TokenCredential interfészt. Ha nincs megadva, az AnonymousCredential lesz használva.

options: StoragePipelineOptions

Opcionális. A HTTP-folyamat konfigurálására vonatkozó beállítások.

Példa a DefaultAzureCredential @azure/identity:

const account = "<storage account name>";

const defaultAzureCredential = new DefaultAzureCredential();

const blobChangeFeedClient = new BlobChangeFeedClient(
  `https://${account}.blob.core.windows.net`,
  defaultAzureCredential
);

Példa fióknév/kulcs használatával:

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

const blobChangeFeedClient = new BlobChangeFeedClient(
  `https://${account}.blob.core.windows.net`,
  sharedKeyCredential
);

changeFeedClientOptions: BlobChangeFeedClientOptions

Metódus adatai

fromConnectionString(string, StoragePipelineOptions, BlobChangeFeedClientOptions)

Létrehozza a BlobChangeFeedClient egy példányát a kapcsolati sztringből.

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

Paraméterek

connectionString: string

Fiókkapcsolati sztring vagy egy Azure Storage-fiók SAS-kapcsolati sztringje. [ Megjegyzés – A fiókkapcsolati sztring csak NODE.JS futtatókörnyezetben használható. ] Példa fiókkapcsolati sztringre – DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net SAS kapcsolati sztring példa – 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

Opcionális. A HTTP-folyamat konfigurálására vonatkozó beállítások.

changeFeedClientOptions: BlobChangeFeedClientOptions

Válaszok

BlobChangeFeedClient

listChanges(BlobChangeFeedListChangesOptions)

Egy aszinkron iterátort ad vissza a megadott fiók összes változáscsatorna-eseményének listázásához.

A .byPage() egy aszinkron iterátort ad vissza a lapok változáscsatorna-eseményeinek listázásához.

Példa for await szintaxis használatára:

let i = 1;
for await (const event of blobChangeFeedClient.listChanges()) {
  console.log(`Event ${i++}, type: ${event.eventType}`);
}

Példa a iter.next() használatára:

let i = 1;
const iter = blobChangeFeedClient.listChanges();
let eventItem = await iter.next();
while (!eventItem.done) {
  console.log(`Event ${i++}, type: ${eventItem.eventType}`);
  eventItem = await iter.next();
}

Példa a byPage() használatára:

// passing optional maxPageSize in the page settings
let i = 1;
for await (const eventPage of blobChangeFeedClient.listChanges().byPage({ maxPageSize: 20 })) {
  if (eventPage.events) {
    for (const event of eventPage.events) {
      console.log(`Event ${i++}, type: ${event.eventType}`);
    }
  }
}

Példa jelölővel ellátott lapozásra:

let i = 1;
let iterator = blobChangeFeedClient.listChanges().byPage({ maxPageSize: 2 });
let eventPage = (await iterator.next()).value;

if (eventPage.events) {
  for (const container of eventPage.events) {
    console.log(`Event ${i++}, type: ${event.eventType}`);
  }
}

// Gets next marker
let marker = eventPage.continuationToken;
// Passing next marker as continuationToken
iterator = blobChangeFeedClient
  .listChanges()
  .byPage({ continuationToken: marker, maxPageSize: 10 });
eventPage = (await iterator.next()).value;

if (eventPage.events) {
  for (const container of eventPage.events) {
     console.log(`Event ${i++}, type: ${event.eventType}`);
  }
}

function listChanges(options?: BlobChangeFeedListChangesOptions): PagedAsyncIterableIterator<BlobChangeFeedEvent, BlobChangeFeedEventPage, PageSettings>

Paraméterek

options: BlobChangeFeedListChangesOptions

A hírcsatorna változási eseményeinek listázási lehetőségei.

Válaszok

PagedAsyncIterableIterator<BlobChangeFeedEvent, BlobChangeFeedEventPage, PageSettings>

Lapozást támogató asyncIterableIterator.

Visszajelzés

Hasznosnak találta ezt az oldalt?

Megosztás a következőn keresztül:

BlobChangeFeedClient class

Konstruktorok

Metódusok

Konstruktor adatai

BlobChangeFeedClient(string, Pipeline)

Paraméterek

BlobChangeFeedClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions, BlobChangeFeedClientOptions)

Paraméterek

Metódus adatai

fromConnectionString(string, StoragePipelineOptions, BlobChangeFeedClientOptions)

Paraméterek

Válaszok

listChanges(BlobChangeFeedListChangesOptions)

Paraméterek

Válaszok

Visszajelzés