Rychlý start: Vytvoření aplikace Durable Functions JavaScriptu

Pomocí Durable Functions, funkce Azure Functions, můžete psát stavové bezserverové pracovní postupy v JavaScriptu. V tomto rychlém startu naklonujete a spustíte ukázkovou aplikaci, která ukazuje dva běžné vzory orchestrace:

  • Řetězení funkcí: Volá aktivity postupně (Tokio → Seattle → Londýn).
  • Fan-out/fan-in: Volá aktivity paralelně napříč pěti městy a pak agreguje výsledky.

Na konci budete mít obě orchestrace spuštěné lokálně pomocí emulátoru Durable Task Scheduler a budete moct zobrazit jejich stav na dashboardu.

  • Naklonujte a připravte ukázkový projekt Hello Cities.
  • Nastavte emulátor plánovače úloh Durable a Azurite pro místní vývoj.
  • Spusťte aplikaci funkcí a aktivujte obě orchestrace.
  • Zkontrolujte stav orchestrace a výstup na řídicím panelu Plánovače úloh Durable.

Předpoklady

Nastavení emulátoru Plánovače úloh Durable

Emulátor plánovače úloh Durable Task Scheduler poskytuje místní vývojové prostředí, abyste mohli otestovat orchestrace bez předplatného Azure. Hostitel Functions také vyžaduje Azurite pro místní úložiště.

Spusťte oba kontejnery:

docker run -d --name dtsemulator -p 8080:8080 -p 8082:8082 \
  mcr.microsoft.com/dts/dts-emulator:latest

docker run -d --name azurite -p 10000:10000 -p 10001:10001 -p 10002:10002 \
  mcr.microsoft.com/azure-storage/azurite

Tip

Jakmile je emulátor spuštěný, můžete přistupovat k řídicímu panelu Durable Task Scheduler na adrese http://localhost:8082, kde můžete sledovat orchestrace.

Spusťte ukázku pro rychlý start

  1. Přejděte do ukázkového adresáře Hello Cities:

    cd samples/durable-functions/javascript/HelloCities

  2. Nainstalujte závislosti:

    npm install

  3. Ověřte, že local.settings.json soubor obsahuje následující konfiguraci:

    {
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "node",
    "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None"
  }
}

  4. Spusťte aplikaci funkcí:

    func start

  5. V samostatném terminálu aktivujte orchestraci řetězení funkcí :

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartChaining
$response

    Odpověď obsahuje stavové adresy URL pro instanci orchestrátoru. statusQueryGetUri Zkopírujte hodnotu a spusťte ji a zkontrolujte výsledek:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  6. Spusťte orchestraci fan-out/fan-in:

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartFanOutFanIn
Invoke-RestMethod -Uri $response.statusQueryGetUri

Očekávaný výstup

Požadavek POST vrátí odpověď JSON s adresami URL stavu. Příklad:

{
  "id": "<instanceId>",
  "statusQueryGetUri": "http://localhost:7071/runtime/webhooks/durabletask/instances/<instanceId>?code=...",
  "sendEventPostUri": "...",
  "terminatePostUri": "...",
  "purgeHistoryDeleteUri": "..."
}

Když zadáte dotaz na statusQueryGetUri a hodnota runtimeStatus orchestrace je Completed, výsledky pozdravu najdete v poli output. Orchestrace zřetězení vrátí:

{
  "name": "chainingOrchestration",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
}

Orchestrace fan-out/fan-in vrací:

{
  "name": "fanOutFanInOrchestration",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!", "Hello Paris!", "Hello Berlin!"]
}

Tip

Pokud se na runtimeStatus zobrazí Running nebo Pending, chvíli počkejte a znovu odešlete dotaz na statusQueryGetUri.

Otevřete řídicí panel Plánovače úloh Durable na adrese http://localhost:8082, abyste zobrazili stav orchestrace a historii spuštění.

Vysvětlení kódu

Ukázka používá programovací model Node.js v4, kde jsou všechny funkce definovány v jednom souboru (src/functions/helloCities.js).

Funkce aktivity

Aktivita sayHello přebírá název města a vrací pozdrav:

df.app.activity("sayHello", {
  handler: (city) => {
    return `Hello ${city}!`;
  },
});

Funkce orchestratoru

Orchestrátor řetězení postupně volá sayHello pro tři města:

df.app.orchestration("chainingOrchestration", function* (context) {
  const outputs = [];
  outputs.push(yield context.df.callActivity("sayHello", "Tokyo"));
  outputs.push(yield context.df.callActivity("sayHello", "Seattle"));
  outputs.push(yield context.df.callActivity("sayHello", "London"));
  return outputs;
});

Orchestrátor fan-out/fan-in plánuje aktivity paralelně:

df.app.orchestration("fanOutFanInOrchestration", function* (context) {
  const cities = ["Tokyo", "Seattle", "London", "Paris", "Berlin"];

  // Fan-out: schedule all activities in parallel
  const tasks = cities.map((city) => context.df.callActivity("sayHello", city));

  // Fan-in: wait for all to complete
  const results = yield context.df.Task.all(tasks);
  return results;
});

Klientské funkce

Funkce klienta aktivované protokolem HTTP spouští každou orchestraci. Například začátek řetězení:

app.http("StartChaining", {
  route: "StartChaining",
  methods: ["POST"],
  authLevel: "anonymous",
  extraInputs: [df.input.durableClient()],
  handler: async (request, context) => {
    const client = df.getClient(context);
    const instanceId = await client.startNew("chainingOrchestration");
    context.log(`Started chaining orchestration with ID = '${instanceId}'.`);
    return client.createCheckStatusResponse(request, instanceId);
  },
});

Konfigurace

Ukázka používá emulátor Plánovače úloh Durable jako back-end úložiště. Toto nastavení je nakonfigurováno v host.json:

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "DurableTask.Core": "Warning"
    }
  },
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}

Vyčistěte zdroje

Po dokončení zastavte kontejnery emulátoru:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Další kroky

  • Last updated on