Snabbstart: Skapa en PowerShell-Durable Functions-app

Använd Durable Functions, en funktion i Azure Functions, för att skriva tillståndskänsliga serverlösa arbetsflöden i PowerShell. I den här snabbstarten ska du klona och köra en exempelapp som visar två vanliga orkestreringsmönster:

• Funktionskedjning: Anropar aktiviteter i följd (Tokyo → Seattle → London).
• Fan-out/fan-in: Anropar aktiviteter parallellt i fem städer och sammanställer sedan resultatet.

När du är klar kommer båda orkestreringarna att köras lokalt med Durable Task Scheduler-emulatorn, och du kan se deras status på instrumentpanelen.

Förutsättningar

• PowerShell 7.4+ installerat.
• Azure Functions Core Tools v4 eller senare.
• Docker för att köra emulatorn och Azurite.
• Klona Durable Task Scheduler GitHub-lagringsplatsen för att använda snabbstartsexemplet.

Konfigurera Durable Task Scheduler-emulatorn

Durable Task Scheduler-emulatorn tillhandahåller en lokal utvecklingsmiljö så att du kan testa orkestreringar utan en Azure prenumeration. PowerShell Functions-värden kräver också Azurite för lokal lagring.

Starta båda containrarna:

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

Kör snabbstartsexemplet

1. Gå till exempelkatalogen Hello Cities:

   cd samples/durable-functions/powershell/HelloCities
   

2. Kontrollera att local.settings.json filen innehåller följande konfiguration:

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

3. Starta funktionsappen:

   func start
   

4. I ett separat terminalfönster startar du orkestreringen för funktionskedjning:

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

   Svaret innehåller status-URL:er för orkestreringsinstansen. Kopiera värdet statusQueryGetUri och kör det för att kontrollera resultatet:

   Invoke-RestMethod -Uri $response.statusQueryGetUri
   

5. Utlös fan-out/fan-in-orkestreringen :

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

Förväntade utdata

POST-begäran returnerar ett JSON-svar med status-URL:er. Ett exempel:

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

När du frågar efter statusQueryGetUri och orkestreringens runtimeStatus är Completed, kan du hitta hälsningsresultaten i fältet output. Länkningsorkestreringen returnerar:

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

Fan-out/fan-in-orkestreringen returnerar följande:

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

Öppna instrumentpanelen för Durable Task Scheduler på http://localhost:8082 för att se orkestreringsstatus och körningshistorik.

Förstå koden

Exempelprojektet använder PowerShell-funktionsmodellen där varje funktion finns i en egen underkatalog med en function.json bindningsfil och ett run.ps1 skript.

Aktivitetsfunktion

Aktiviteten SayHello (SayHello/run.ps1) tar ett stadsnamn och returnerar en hälsning:

param($city)

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

Orkestratorfunktioner

Den sammanlänkande orkestratorn (ChainingOrchestration/run.ps1) anropar SayHello sekventiellt för tre städer:

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

Fan-out/fan-in orchestrator (FanOutFanInOrchestration/run.ps1) schemalägger aktiviteter parallellt:

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

Klientfunktioner

Klientfunktioner som utlöses via HTTP startar varje orkestrering. Till exempel 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

Konfiguration

Exemplet använder Durable Task Scheduler-emulatorn som lagringsbackend. Detta konfigureras i 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
  }
}

Inställningen managedDependency installerar automatiskt nödvändiga PowerShell-moduler som definierats i requirements.psd1, inklusive Durable Functions SDK.

Rensa resurser

Stoppa emulatorcontainrarna när du är klar:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Nästa steg

• Läs mer om vanliga Durable Functions applikationsmönster.
• Granska den fristående PowerShell SDK-guiden.
• Lär dig mer om Durable Functions lagringsproviders.