DurableClient class

用戶端,用於啟動、查詢、終止和引發事件至協調流程和實體實例。

屬性

taskHubName

在此協調流程用戶端實例上設定的工作中樞名稱。

方法

createCheckStatusResponse(undefined | HttpRequest, string)

建立用於檢查指定實例狀態的 HTTP 回應。

createHttpManagementPayload(string)

建立包含實例管理 HTTP 端點的 HttpManagementPayload 物件。

getStatus(string, GetStatusOptions)

取得指定協調流程實例的狀態。

getStatusAll()

取得所有協調流程實例的狀態。

getStatusBy(OrchestrationFilter)

取得符合指定條件之所有協調流程實例的狀態。

purgeInstanceHistory(string)

清除特定協調流程實例的歷程記錄。

purgeInstanceHistoryBy(OrchestrationFilter)

清除符合條件之實例的協調流程歷程記錄。

raiseEvent(string, string, unknown, TaskHubOptions)

將事件通知訊息傳送至等候的協調流程實例。

readEntityState<T>(EntityId, TaskHubOptions)

嘗試讀取實體的目前狀態。 如果實體不存在,或實體的 JSON 串行化狀態大於 16KB,則傳回未定義。

rewind(string, string, TaskHubOptions)

以原因倒轉指定的失敗協調流程實例。

signalEntity(EntityId, string, unknown, TaskHubOptions)

發出實體執行作業的訊號。

startNew(string, StartNewOptions)

啟動指定協調器函式的新實例。

如果已存在具有指定標識符的協調流程實例,現有的實例將會以無訊息方式取代這個新實例。

terminate(string, string)

終止執行中的協調流程實例。

waitForCompletionOrCreateCheckStatusResponse(HttpRequest, string, WaitForCompletionOptions)

建立 HTTP 回應,其中包含非已完成實例的管理 URL 承載,或包含包含已完成協調流程輸出的承載。

如果協調流程未在指定的逾時內完成,則 HTTP 回應會與 createCheckStatusResponse() 的回應相同。

屬性詳細資料

taskHubName

在此協調流程用戶端實例上設定的工作中樞名稱。

taskHubName: string

屬性值

string

方法詳細資料

createCheckStatusResponse(undefined | HttpRequest, string)

建立用於檢查指定實例狀態的 HTTP 回應。

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

參數

request

undefined | HttpRequest

觸發目前協調流程實例的 HTTP 要求。

instanceId

string

要檢查之協調流程實例的標識碼。

傳回

具有 Location 標頭的 HTTP 202 回應,以及包含實例管理 URL 的承載。

createHttpManagementPayload(string)

建立包含實例管理 HTTP 端點的 HttpManagementPayload 物件。

function createHttpManagementPayload(instanceId: string): HttpManagementPayload

參數

instanceId

string

要檢查之協調流程實例的標識碼。

傳回

getStatus(string, GetStatusOptions)

取得指定協調流程實例的狀態。

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

參數

instanceId

string

要查詢之協調流程實例的標識碼。

options
GetStatusOptions

options 物件,指定額外的組態

傳回

getStatusAll()

取得所有協調流程實例的狀態。

function getStatusAll(): Promise<DurableOrchestrationStatus[]>

傳回

getStatusBy(OrchestrationFilter)

取得符合指定條件之所有協調流程實例的狀態。

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

參數

filter
OrchestrationFilter

OrchestrationFilter 物件,指定要擷取的協調流程。

傳回

purgeInstanceHistory(string)

清除特定協調流程實例的歷程記錄。

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

參數

instanceId

string

要清除之協調流程實例的標識碼。

傳回

purgeInstanceHistoryBy(OrchestrationFilter)

清除符合條件之實例的協調流程歷程記錄。

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

參數

filter
OrchestrationFilter

OrchestrationFilter 物件,指定要清除的協調流程。

傳回

raiseEvent(string, string, unknown, TaskHubOptions)

將事件通知訊息傳送至等候的協調流程實例。

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

參數

instanceId

string

將處理事件的協調流程實例標識碼。

eventName

string

事件的名稱。

eventData

unknown

與事件相關聯的 JSON 可串行化數據。

options
TaskHubOptions

物件,提供協調流程實例的TaskHubName及其相關聯連接字串的名稱

傳回

Promise<void>

承諾,會在事件通知訊息加入佇列時解決。

若要處理事件,目標協調流程實例必須使用 eventName等候名為 waitForExternalEvent(string) 的事件。

如果找不到指定的實例或未執行,此作業將不會有任何作用。

readEntityState<T>(EntityId, TaskHubOptions)

嘗試讀取實體的目前狀態。 如果實體不存在,或實體的 JSON 串行化狀態大於 16KB,則傳回未定義。

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

參數

entityId
EntityId

目標實體。

options
TaskHubOptions

選擇性物件,提供目標實體的TaskHubName及其相關聯連接字串的名稱

傳回

Promise<EntityStateResponse<T>>

包含實體目前狀態的回應。

rewind(string, string, TaskHubOptions)

以原因倒轉指定的失敗協調流程實例。

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

參數

instanceId

string

要倒轉之協調流程實例的標識碼。

reason

string

倒轉協調流程實例的原因。

options
TaskHubOptions

物件,提供協調流程實例的TaskHubName及其相關聯連接字串的名稱

傳回

Promise<void>

當倒轉訊息加入佇列時解析的承諾。

這項功能目前為預覽狀態。

signalEntity(EntityId, string, unknown, TaskHubOptions)

發出實體執行作業的訊號。

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

參數

entityId
EntityId

目標實體。

operationName

string

作業的名稱。

operationContent

unknown

作業的內容。

options
TaskHubOptions

物件,提供實體實例的TaskHubName及其相關聯連接字串的名稱

傳回

Promise<void>

startNew(string, StartNewOptions)

啟動指定協調器函式的新實例。

如果已存在具有指定標識符的協調流程實例,現有的實例將會以無訊息方式取代這個新實例。

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

參數

orchestratorFunctionName

string

要啟動的協調器函式名稱。

options
StartNewOptions

選擇性物件來控制排程的協調器(例如提供輸入、instanceID)

傳回

Promise<string>

新協調流程實例的標識碼。

terminate(string, string)

終止執行中的協調流程實例。

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

參數

instanceId

string

要終止之協調流程實例的標識碼。

reason

string

終止協調流程實例的原因。

傳回

Promise<void>

在佇列終止訊息時解析的承諾。

終止協調流程實例不會影響目前協調流程實例啟動的任何即時活動函式執行或子協調流程。

waitForCompletionOrCreateCheckStatusResponse(HttpRequest, string, WaitForCompletionOptions)

建立 HTTP 回應,其中包含非已完成實例的管理 URL 承載,或包含包含已完成協調流程輸出的承載。

如果協調流程未在指定的逾時內完成,則 HTTP 回應會與 createCheckStatusResponse() 的回應相同。

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

參數

request
HttpRequest

觸發目前函式的 HTTP 要求。

instanceId

string

要檢查之實例的唯一標識符。

waitOptions
WaitForCompletionOptions

options 物件,指定等候長期函式輸出的逾時時間,以及檢查輸出的頻率。

傳回

Promise<HttpResponse>