DurableClient class
Client zum Starten, Abfragen, Beenden und Auslösen von Ereignissen für Orchestrierung und Entitätsinstanzen.
Eigenschaften
| task |
Der Name des Aufgabenhubs, der auf dieser Orchestrierungsclientinstanz konfiguriert ist. |
Methoden
| create |
Erstellt eine HTTP-Antwort, die nützlich ist, um den Status der angegebenen Instanz zu überprüfen. |
| create |
Erstellt ein HttpManagementPayload--Objekt, das HTTP-Endpunkte für die Instanzverwaltung enthält. |
| get |
Ruft den Status der angegebenen Orchestrierungsinstanz ab. |
| get |
Ruft den Status aller Orchestrierungsinstanzen ab. |
| get |
Ruft den Status aller Orchestrierungsinstanzen ab, die den angegebenen Bedingungen entsprechen. |
| purge |
Löscht den Verlauf für eine bestimmte Orchestrierungsinstanz. |
| purge |
Löschen Sie den Orchestrierungsverlauf für Instanzen, die den Bedingungen entsprechen. |
| raise |
Sendet eine Ereignisbenachrichtigung an eine wartende Orchestrierungsinstanz. |
| read |
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, Task |
Gibt die angegebene fehlgeschlagene Orchestrierungsinstanz aus einem Grund zurück. |
| signal |
Signalisiert eine Entität zum Ausführen eines Vorgangs. |
| start |
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. |
| wait |
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
Promise<DurableOrchestrationStatus>
getStatusAll()
Ruft den Status aller Orchestrierungsinstanzen ab.
function getStatusAll(): Promise<DurableOrchestrationStatus[]>
Gibt zurück
Promise<DurableOrchestrationStatus[]>
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
Promise<DurableOrchestrationStatus[]>
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
Promise<PurgeHistoryResult>
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
Promise<PurgeHistoryResult>
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>