Schnellstart: Erstellen einer PowerShell-Durable Functions-App

Verwenden Sie Durable Functions, eine Funktion von Azure Functions, um zustandsbehaftete serverlose Workflows in PowerShell zu erstellen. In dieser Schnellstartanleitung klonen und führen Sie eine Beispiel-App aus, die zwei gängige Orchestrierungsmuster veranschaulicht:

  • Funktionskette: Ruft Aktivitäten sequenziell auf (Tokio → Seattle → London).
  • Fan-out/Fan-In: Ruft Aktivitäten parallel in fünf Städten auf und aggregiert dann die Ergebnisse.

Am Ende haben Sie beide Orchestrierungen lokal mit dem Emulator " Durable Task Scheduler " ausgeführt und können ihren Status im Dashboard anzeigen.

  • Klonen Sie das Hello Cities-Beispielprojekt, und bereiten Sie es vor.
  • Richten Sie den Emulator "Durable Task Scheduler" und "Azurite" für die lokale Entwicklung ein.
  • Führen Sie die Funktions-App aus und lösen Sie beide Orchestrierungen aus.
  • Überprüfen Sie den Orchestrierungsstatus und die Ausgabe im Durable Task Scheduler-Dashboard.

Voraussetzungen

Einrichten des Emulators "Durable Task Scheduler"

Der Emulator Durable Task Scheduler stellt eine lokale Entwicklungsumgebung bereit, sodass Sie Orchestrierungen ohne Azure Abonnement testen können. Der PowerShell-Funktionen-Host erfordert auch Azurite für lokalen Speicher.

Starten Sie beide Container:

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

Sobald der Emulator ausgeführt wird, können Sie auf das Dashboard http://localhost:8082 "Durable Task Scheduler" zugreifen, um Orchestrierungen zu überwachen.

Ausführen des Schnellstartbeispiels

  1. Navigieren Sie zum Beispielverzeichnis "Hello Cities":

    cd samples/durable-functions/powershell/HelloCities

  2. Stellen Sie sicher, dass die local.settings.json Datei die folgende Konfiguration enthält:

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

  3. Starten Sie die Funktions-App:

    func start

  4. Starten Sie in einem separaten Terminal die Orchestrierung der Verkettung von Funktionen:

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

    Die Antwort enthält Status-URLs für die Orchestrierungsinstanz. Kopieren Sie den statusQueryGetUri Wert, und führen Sie ihn aus, um das Ergebnis zu überprüfen:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  5. Auslösen der Fanout-/Fan-In-Orchestrierung :

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

Erwartete Ausgabe

Die POST-Anforderung gibt eine JSON-Antwort mit Status-URLs zurück. Zum Beispiel:

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

Wenn Sie statusQueryGetUri abfragen und der runtimeStatus der Orchestrierung Completed ist, finden Sie die Begrüßungsergebnisse im Feld output. Die Verkettungs-Orchestrierung gibt Folgendes zurück:

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

Die Fan-out/Fan-in-Orchestrierung liefert Folgendes zurück:

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

Tip

Wenn runtimeStatusRunning oder Pending anzeigt, warten Sie kurz und fragen Sie statusQueryGetUri erneut ab.

Öffnen Sie das Durable Task Scheduler-Dashboard unter http://localhost:8082, um den Orchestrierungsstatus und den Ausführungsverlauf einzusehen.

Grundlegendes zum Code

Das Beispielprojekt verwendet das PowerShell-Funktionsmodell, in dem sich jede Funktion in einem eigenen Unterverzeichnis mit einer function.json Bindungsdatei und einem run.ps1 Skript befindet.

Aktivitätsfunktion

Die SayHello Aktivität (SayHello/run.ps1) nimmt einen Stadtnamen und gibt eine Begrüßung zurück:

param($city)

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

Orchestratorfunktionen

Der Verkettungs-Orchestrator (ChainingOrchestration/run.ps1) ruft sequenziell für drei Städte auf SayHello :

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

Der Fan-out/Fan-in-Orchestrator (FanOutFanInOrchestration/run.ps1) plant Aktivitäten parallel:

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

Clientfunktionen

Durch HTTP ausgelöste Clientfunktionen starten jede Orchestrierung. Beispiel: 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

Im Beispiel wird der Emulator "Durable Task Scheduler" als Speicher-Back-End verwendet. Dies ist konfiguriert in 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
  }
}

Die Einstellung managedDependency installiert automatisch die erforderlichen PowerShell-Module, die in requirements.psd1 definiert sind, einschließlich des Durable Functions SDK.

Bereinigen von Ressourcen

Beenden Sie die Emulatorcontainer, wenn Sie fertig sind:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Nächste Schritte

  • Last updated on