Rövid útmutató: PowerShell-Durable Functions-alkalmazás létrehozása

A Azure Functions Durable Functions használatával állapotalapú kiszolgáló nélküli munkafolyamatokat írhat a PowerShellben. Ebben a rövid útmutatóban klónozhat és futtathat egy mintaalkalmazást, amely két gyakori vezénylési mintát mutat be:

  • Függvényláncolás: Egymás után hívja meg a tevékenységeket (Tokió → Seattle → London).
  • Fan-out/fan-in: A tevékenységek párhuzamos meghívása öt városra vonatkozóan, majd az eredmények összesítése.

A folyamat végére mindkét orchestráció helyben fog futni a Durable Task Scheduler emulátorral, és az állapotukat a kezelőpulton is láthatja.

  • Klónozza és készítse elő a Hello Cities mintaprojektet.
  • Állítsa be a Durable Task Scheduler emulatort és az Azurite-t a helyi fejlesztéshez.
  • Futtassa a függvényalkalmazást, és indítsa el mindkét orkesztrációt.
  • Tekintse meg a vezénylési folyamat állapotát és kimenetét a Durable Task Scheduler irányítópultján.

Prerequisites

A Durable Task Scheduler emulátor beállítása

A Durable Task Scheduler emulator helyi fejlesztési környezetet biztosít, így Azure előfizetés nélkül tesztelheti a vezényléseket. A PowerShell Functions-gazdagéphez az Azurite is szükséges a helyi tároláshoz.

Indítsa el mindkét tárolót:

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

Miután az emulátor elindult, a http://localhost:8082 címen elérheti a Durable Task Scheduler irányítópultját az orchesztrációk figyeléséhez.

A gyorsútmutató-minta futtatása

  1. Keresse meg a Hello Cities mintakönyvtárat:

    cd samples/durable-functions/powershell/HelloCities

  2. Ellenőrizze, hogy a local.settings.json fájl a következő konfigurációt tartalmazza-e:

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

  3. Indítsa el a függvényalkalmazást:

    func start

  4. Egy másik terminálban indítsa el a függvényláncolási koordinálást:

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

    A válasz az orchestrationpéldányhoz tartozó állapotra vonatkozó URL-címeket tartalmaz. Másolja ki az értéket, statusQueryGetUri és futtassa az eredmény ellenőrzéséhez:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  5. Indítsa el a fan-out/fan-in hangszerelést:

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

Várt kimenet

A POST-kérelem állapot URL-címekkel rendelkező JSON-választ ad vissza. Például:

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

Amikor lekérdezi a(z) statusQueryGetUri elemet, és az orchestráció runtimeStatus értéke Completed, az üdvözlési eredményeket a(z) output mezőben találja. A láncolás vezénylése a következőt adja vissza:

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

A fan-out/fan-in vezénylés az alábbit adja vissza:

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

Tip

Ha a(z) runtimeStatus helyén Running vagy Pending jelenik meg, várjon egy pillanatot, majd kérdezze le újra a(z) statusQueryGetUri-t.

Nyissa meg a Durable Task Scheduler irányítópultját a következő címen: http://localhost:8082, hogy megtekinthesse az orchesztráció állapotát és a végrehajtási előzményeket.

A kód értelmezése

A mintaprojekt a PowerShell-függvénymodellt használja, ahol minden függvény a saját alkönyvtárában található egy function.json kötésfájllal és egy run.ps1 szkripttel.

Tevékenységfüggvény

A SayHello tevékenység (SayHello/run.ps1) egy városnevet vesz fel, és egy üdvözlést ad vissza:

param($city)

Write-Host "Saying hello to $city."
"Hello $city!"

Orchestrator-függvények

A láncoló vezénylő (ChainingOrchestration/run.ps1) egymás után hív SayHello meg három várost:

param($Context)

$output = @()
$output += Invoke-DurableActivity -FunctionName 'SayHello' -Input 'Tokyo'
$output += Invoke-DurableActivity -FunctionName 'SayHello' -Input 'Seattle'
$output += Invoke-DurableActivity -FunctionName 'SayHello' -Input 'London'

$output

A fan-out/fan-in hangoló (FanOutFanInOrchestration/run.ps1) párhuzamosan ütemezi a tevékenységeket:

param($Context)

$cities = @('Tokyo', 'Seattle', 'London', 'Paris', 'Berlin')

# Fan-out: schedule all activities in parallel
$parallelTasks = @()
foreach ($city in $cities) {
    $parallelTasks += Invoke-DurableActivity -FunctionName 'SayHello' -Input $city -NoWait
}

# Fan-in: wait for all to complete
$output = Wait-ActivityFunction -Task $parallelTasks

$output

Klienstől függő funkciók

A HTTP által kiváltott kliensfüggvények indítják el az egyes orchestrációkat. Például StartChaining/run.ps1:

param($Request, $TriggerMetadata)

$instanceId = Start-DurableOrchestration -FunctionName 'ChainingOrchestration'
Write-Host "Started chaining orchestration with ID = '$instanceId'."

$response = New-DurableOrchestrationCheckStatusResponse -Request $Request -InstanceId $instanceId
Push-OutputBinding -Name Response -Value $response

Konfiguráció

A minta a Durable Task Scheduler emulatort használja a tároló háttérrendszereként. Ez itt van konfigurálva: host.json

{
  "version": "2.0",
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  },
  "managedDependency": {
    "enabled": true
  }
}

A managedDependency beállítás automatikusan telepíti a requirements.psd1-ben meghatározott szükséges PowerShell-modulokat, beleértve a Durable Functions SDK-t is.

Erőforrások tisztítása

Ha végzett, állítsa le az emulátortárolókat:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Következő lépések

  • Last updated on