durable-functions package

Při selhání context.df.Task.all() došlo k konkrétní chybě. Zpráva obsahuje agregaci všech výjimek, které selhaly. Měl by se řídit následujícím formátem:

context.df.Task.all() zjistil následující chybové zprávy:

Název: DurableError Message: Funkce aktivity ActivityA se nezdařila. StackTrace: <Trasování zásobníku>

Název: DurableError Message: Funkce aktivity ActivityB se nezdařila. StackTrace: <Trasování zásobníku>

Kontext entity s fiktivními výchozími hodnotami, které usnadňují napodobování a zakrývání rozhraní API Durable Functions.

Kontext orchestrace s fiktivními výchozími hodnotami, které usnadňují napodobování/stubbování rozhraní API Durable Functions.

Klient pro spouštění, dotazování, ukončování a vyvolávání událostí pro orchestraci a instance entit.

Specfická chyba vyvolaná v případě, že plánovaná aktivita nebo suborchestrator selhala. Tuto chybu je možné zkontrolovat prostřednictvím ochrany instanceof a zachytit pouze výjimky vyvolané knihovnou DurableJS.

Poskytuje funkce pro kód aplikace, který implementuje operaci orchestrace.

Představuje stav trvalé instance orchestrace.

Lze načíst pomocí DurableClient.getStatus()

Jedinečný identifikátor entity, který se skládá z třídy entity a klíče entity.

Odpověď vrácená DurableClient.readEntityState().

Datová struktura obsahující koncové body HTTP správy instancí

Implementace zdroje tokenů pro spravované identity Azure.

příklad

Seznam předplatných Azure získáte voláním rozhraní HTTP API Azure Resource Manageru.

const df = require("durable-functions");

df.app.orchestration(function* (context) {
  return yield context.df.callHttp({
      method: "GET",
      url: "https://management.azure.com/subscriptions?api-version=2019-06-01",
      tokenSource: df.ManagedIdentityTokenSource("https://management.core.windows.net"),
  });
});

Třída, která má uchovávat statistiky o tomto provádění historie vyprázdnění. Návratový typ DurableClient.purgeHistory()

Definuje zásady opakování, které lze předat jako parametry různým operacím.

Objekt Options poskytnutý pro callHttp() metody v kontextech orchestrace

Konfiguruje vstupy, výstupy a obslužnou rutinu pro funkci Durable Client.

Poskytuje funkce pro kód aplikace, který implementuje operaci entity.

Kontextový objekt předaný funkcím entity.

Objekt Options předaný metodě getStatus() klienta

Konfiguruje možnosti pro funkci Durable Client aktivovanou protokolem HTTP.

Kontextový objekt předaný funkcím orchestrace

Objekt Options předaný rozhraním DURABLEClient API k filtrování orchestrací, na kterých se mají provádět akce

Úloha Durable Functions.

Úloha Durable Functions.

Objekt Options poskytnutý jako volitelný druhý argument pro metodu client.startNew()

Úloha Durable Functions.

Objekt Options předaný rozhraním DURABLEClient API k určení vlastností centra úloh

Konfiguruje možnosti pro funkci Durable Client aktivovanou časovačem.

Vráceno z DurableClient.createTimer(Date), pokud volání není yield-ed. Představuje čekající časovač. Další informace najdete v dokumentaci k úloze.

Všechny čekající časovače musí být dokončeny nebo zrušeny, aby se orchestrace dokončila.

příklad

Zrušení časovače

// calculate expiration date
const timeoutTask = context.df.createTimer(expirationDate);

// do some work

if (!timeoutTask.isCompleted) {
    // An orchestration won't get marked as completed until all its scheduled
    // tasks have returned, or been cancelled. Therefore, it is important
    // to cancel timers when they're no longer needed
    timeoutTask.cancel();
}

příklad

Vytvoření časového limitu

const now = Date.now();
const expiration = new Date(now.valueOf()).setMinutes(now.getMinutes() + 30);

const timeoutTask = context.df.createTimer(expirationDate);
const otherTask = context.df.callActivity("DoWork");

const winner = yield context.df.Task.any([timeoutTask, otherTask]);

if (winner === otherTask) {
    // do some more work
}

if (!timeoutTask.isCompleted) {
    // An orchestration won't get marked as completed until all its scheduled
    // tasks have returned, or been cancelled. Therefore, it is important
    // to cancel timers when they're no longer needed
    timeoutTask.cancel();
}

Objekt Options předaný metodě durableClient.waitForCompletionOrCreateCheckStatusResponse() k určení časových limitů, jak dlouho čekat na výstup z odolné funkce a jak často se má zkontrolovat výstup.

Typ funkce obslužné rutiny, která je aktivována některými triggery a přijímá DurableClient instanci jako vstup.

Typ generátoru, který lze zaregistrovat jako orchestraci

Stav instance orchestrace

Vrátí instanci OrchestrationClient.