DurableClient class

Client zum Starten, Abfragen, Beenden und Auslösen von Ereignissen für Orchestrierung und Entitätsinstanzen.

Eigenschaften

taskHubName

Der Name des Aufgabenhubs, der auf dieser Orchestrierungsclientinstanz konfiguriert ist.

Methoden

createCheckStatusResponse(undefined | HttpRequest, string)

Erstellt eine HTTP-Antwort, die nützlich ist, um den Status der angegebenen Instanz zu überprüfen.

createHttpManagementPayload(string)

Erstellt ein HttpManagementPayload--Objekt, das HTTP-Endpunkte für die Instanzverwaltung enthält.

getStatus(string, GetStatusOptions)

Ruft den Status der angegebenen Orchestrierungsinstanz ab.

getStatusAll()

Ruft den Status aller Orchestrierungsinstanzen ab.

getStatusBy(OrchestrationFilter)

Ruft den Status aller Orchestrierungsinstanzen ab, die den angegebenen Bedingungen entsprechen.

purgeInstanceHistory(string)

Löscht den Verlauf für eine bestimmte Orchestrierungsinstanz.

purgeInstanceHistoryBy(OrchestrationFilter)

Löschen Sie den Orchestrierungsverlauf für Instanzen, die den Bedingungen entsprechen.

raiseEvent(string, string, unknown, TaskHubOptions)

Sendet eine Ereignisbenachrichtigung an eine wartende Orchestrierungsinstanz.

readEntityState<T>(EntityId, TaskHubOptions)

Versucht, den aktuellen Status einer Entität zu lesen. Gibt nicht definiert zurück, wenn die Entität nicht vorhanden ist oder der JSON-serialisierte Zustand der Entität größer als 16 KB ist.

rewind(string, string, TaskHubOptions)

Gibt die angegebene fehlgeschlagene Orchestrierungsinstanz aus einem Grund zurück.

signalEntity(EntityId, string, unknown, TaskHubOptions)

Signalisiert eine Entität zum Ausführen eines Vorgangs.

startNew(string, StartNewOptions)

Startet eine neue Instanz der angegebenen Orchestratorfunktion.

Wenn bereits eine Orchestrierungsinstanz mit der angegebenen ID vorhanden ist, wird die vorhandene Instanz automatisch durch diese neue Instanz ersetzt.

terminate(string, string)

Beendet eine ausgeführte Orchestrierungsinstanz.

waitForCompletionOrCreateCheckStatusResponse(HttpRequest, string, WaitForCompletionOptions)

Erstellt eine HTTP-Antwort, die entweder eine Nutzlast von Verwaltungs-URLs für eine nicht abgeschlossene Instanz enthält oder die Nutzlast enthält, die die Ausgabe der abgeschlossenen Orchestrierung enthält.

Wenn die Orchestrierung nicht innerhalb des angegebenen Timeouts abgeschlossen ist, ist die HTTP-Antwort mit der von createCheckStatusResponse() identisch.

Details zur Eigenschaft

taskHubName

Der Name des Aufgabenhubs, der auf dieser Orchestrierungsclientinstanz konfiguriert ist.

taskHubName: string

Eigenschaftswert

string

Details zur Methode

createCheckStatusResponse(undefined | HttpRequest, string)

Erstellt eine HTTP-Antwort, die nützlich ist, um den Status der angegebenen Instanz zu überprüfen.

function createCheckStatusResponse(request: undefined | HttpRequest, instanceId: string): HttpResponse

Parameter

request

undefined | HttpRequest

Die HTTP-Anforderung, die die aktuelle Orchestrierungsinstanz ausgelöst hat.

instanceId

string

Die ID der zu überprüfenden Orchestrierungsinstanz.

Gibt zurück

Eine HTTP 202-Antwort mit einem Location-Header und einer Nutzlast mit Instanzverwaltungs-URLs.

createHttpManagementPayload(string)

Erstellt ein HttpManagementPayload--Objekt, das HTTP-Endpunkte für die Instanzverwaltung enthält.

function createHttpManagementPayload(instanceId: string): HttpManagementPayload

Parameter

instanceId

string

Die ID der zu überprüfenden Orchestrierungsinstanz.

Gibt zurück

getStatus(string, GetStatusOptions)

Ruft den Status der angegebenen Orchestrierungsinstanz ab.

function getStatus(instanceId: string, options?: GetStatusOptions): Promise<DurableOrchestrationStatus>

Parameter

instanceId

string

Die ID der zu abfragenden Orchestrierungsinstanz.

options
GetStatusOptions

options-Objekt, das zusätzliche Konfiguration angibt

Gibt zurück

getStatusAll()

Ruft den Status aller Orchestrierungsinstanzen ab.

function getStatusAll(): Promise<DurableOrchestrationStatus[]>

Gibt zurück

getStatusBy(OrchestrationFilter)

Ruft den Status aller Orchestrierungsinstanzen ab, die den angegebenen Bedingungen entsprechen.

function getStatusBy(filter: OrchestrationFilter): Promise<DurableOrchestrationStatus[]>

Parameter

filter
OrchestrationFilter

das OrchestrationFilter-Objekt, das angibt, welche Orchestrierungen abgerufen werden sollen.

Gibt zurück

purgeInstanceHistory(string)

Löscht den Verlauf für eine bestimmte Orchestrierungsinstanz.

function purgeInstanceHistory(instanceId: string): Promise<PurgeHistoryResult>

Parameter

instanceId

string

Die ID der zu löschenden Orchestrierungsinstanz.

Gibt zurück

purgeInstanceHistoryBy(OrchestrationFilter)

Löschen Sie den Orchestrierungsverlauf für Instanzen, die den Bedingungen entsprechen.

function purgeInstanceHistoryBy(filter: OrchestrationFilter): Promise<PurgeHistoryResult>

Parameter

filter
OrchestrationFilter

das OrchestrationFilter-Objekt, das angibt, welche Orchestrierungen gelöscht werden sollen.

Gibt zurück

raiseEvent(string, string, unknown, TaskHubOptions)

Sendet eine Ereignisbenachrichtigung an eine wartende Orchestrierungsinstanz.

function raiseEvent(instanceId: string, eventName: string, eventData: unknown, options?: TaskHubOptions): Promise<void>

Parameter

instanceId

string

Die ID der Orchestrierungsinstanz, die das Ereignis behandelt.

eventName

string

Der Name des Ereignisses.

eventData

unknown

Die JSON-serialisierbaren Daten, die dem Ereignis zugeordnet sind.

options
TaskHubOptions

Objekt, das TaskHubName der Orchestrierungsinstanz und den Namen der zugeordneten Verbindungszeichenfolge bereitstellt

Gibt zurück

Promise<void>

Eine Zusage, die aufgelöst wird, wenn die Ereignisbenachrichtigung enqueued wurde.

Um das Ereignis zu behandeln, muss die Ziel-Orchestrierungsinstanz auf ein Ereignis mit dem Namen eventName mit waitForExternalEvent(string)warten.

Wenn die angegebene Instanz nicht gefunden wird oder nicht ausgeführt wird, hat dieser Vorgang keine Auswirkung.

readEntityState<T>(EntityId, TaskHubOptions)

Versucht, den aktuellen Status einer Entität zu lesen. Gibt nicht definiert zurück, wenn die Entität nicht vorhanden ist oder der JSON-serialisierte Zustand der Entität größer als 16 KB ist.

function readEntityState<T>(entityId: EntityId, options?: TaskHubOptions): Promise<EntityStateResponse<T>>

Parameter

entityId
EntityId

Die Zielentität.

options
TaskHubOptions

optionales Objekt, das taskHubName der Zielentität und den Namen der zugeordneten Verbindungszeichenfolge bereitstellt

Gibt zurück

Promise<EntityStateResponse<T>>

Eine Antwort, die den aktuellen Status der Entität enthält.

rewind(string, string, TaskHubOptions)

Gibt die angegebene fehlgeschlagene Orchestrierungsinstanz aus einem Grund zurück.

function rewind(instanceId: string, reason: string, options?: TaskHubOptions): Promise<void>

Parameter

instanceId

string

Die ID der Orchestrierungsinstanz, die zurückspulen soll.

reason

string

Der Grund für das Zurückspulen der Orchestrierungsinstanz.

options
TaskHubOptions

Objekt, das TaskHubName der Orchestrierungsinstanz und den Namen der zugeordneten Verbindungszeichenfolge bereitstellt

Gibt zurück

Promise<void>

Eine Zusage, die aufgelöst wird, wenn die Rückspulennachricht abgefragt wird.

Dieses Feature befindet sich derzeit in der Vorschau.

signalEntity(EntityId, string, unknown, TaskHubOptions)

Signalisiert eine Entität zum Ausführen eines Vorgangs.

function signalEntity(entityId: EntityId, operationName?: string, operationContent?: unknown, options?: TaskHubOptions): Promise<void>

Parameter

entityId
EntityId

Die Zielentität.

operationName

string

Der Name des Vorgangs.

operationContent

unknown

Der Inhalt für den Vorgang.

options
TaskHubOptions

Objekt, das TaskHubName der Entitätsinstanz und den Namen der zugeordneten Verbindungszeichenfolge bereitstellt

Gibt zurück

Promise<void>

startNew(string, StartNewOptions)

Startet eine neue Instanz der angegebenen Orchestratorfunktion.

Wenn bereits eine Orchestrierungsinstanz mit der angegebenen ID vorhanden ist, wird die vorhandene Instanz automatisch durch diese neue Instanz ersetzt.

function startNew(orchestratorFunctionName: string, options?: StartNewOptions): Promise<string>

Parameter

orchestratorFunctionName

string

Der Name der orchestrator-Funktion, die gestartet werden soll.

options
StartNewOptions

optionales Objekt zum Steuern des geplanten Orchestrators (z. B. Eingabe, InstanceID)

Gibt zurück

Promise<string>

Die ID der neuen Orchestrierungsinstanz.

terminate(string, string)

Beendet eine ausgeführte Orchestrierungsinstanz.

function terminate(instanceId: string, reason: string): Promise<void>

Parameter

instanceId

string

Die ID der zu beendenden Orchestrierungsinstanz.

reason

string

Der Grund für das Beenden der Orchestrierungsinstanz.

Gibt zurück

Promise<void>

Eine Zusage, die aufgelöst wird, wenn die Beendigungsnachricht enqueuiert wird.

Das Beenden einer Orchestrierungsinstanz hat keine Auswirkungen auf Ausführungen von In-Flight-Aktivitätsfunktionen oder Unter-Orchestrierungen, die von der aktuellen Orchestrierungsinstanz gestartet wurden.

waitForCompletionOrCreateCheckStatusResponse(HttpRequest, string, WaitForCompletionOptions)

Erstellt eine HTTP-Antwort, die entweder eine Nutzlast von Verwaltungs-URLs für eine nicht abgeschlossene Instanz enthält oder die Nutzlast enthält, die die Ausgabe der abgeschlossenen Orchestrierung enthält.

Wenn die Orchestrierung nicht innerhalb des angegebenen Timeouts abgeschlossen ist, ist die HTTP-Antwort mit der von createCheckStatusResponse() identisch.

function waitForCompletionOrCreateCheckStatusResponse(request: HttpRequest, instanceId: string, waitOptions?: WaitForCompletionOptions): Promise<HttpResponse>

Parameter

request
HttpRequest

Die HTTP-Anforderung, die die aktuelle Funktion ausgelöst hat.

instanceId

string

Die eindeutige ID der zu überprüfenden Instanz.

waitOptions
WaitForCompletionOptions

options-Objekt, das die Zeitüberschreitungen angibt, wie lange auf die Ausgabe der dauerhaften Funktion gewartet werden soll und wie oft nach Ausgabe gesucht werden soll.

Gibt zurück

Promise<HttpResponse>