Hızlı Başlangıç: PowerShell Dayanıklı İşlevler uygulaması oluşturma

PowerShell'de durum bilgisi olan sunucusuz iş akışları yazmak için Azure İşlevleri özelliği olan Dayanıklı İşlevler kullanın. Bu hızlı başlangıçta, iki yaygın düzenleme desenini gösteren bir örnek uygulamayı kopyalayıp çalıştıracaksınız:

  • İşlev zinciri: Etkinlikleri sırayla çağırır (Tokyo → Seattle → Londra).
  • Fan-out/fan-in: Beş şehirde etkinlikleri paralel olarak çağırır ve ardından sonuçları toplar.

Sonunda, Durable Task Scheduler öykünücüsünde yerel olarak çalışan her iki orkestrasyona da sahip olacak ve bunların durumunu gösterge panelinde görüntüleyebileceksiniz.

  • Hello Cities örnek projesini kopyalayın ve hazırlayın.
  • Yerel geliştirme için Durable Task Scheduler öykünücüsünü ve Azurite'yi kurup yapılandırın.
  • İşlev uygulamasını çalıştırın ve her iki orkestrasyonu da tetikleyin.
  • Dayanıklı Görev Zamanlayıcı panosunda düzenleme durumunu ve çıktıyı gözden geçirin.

Prerequisites

Dayanıklı Görev Zamanlayıcı öykünücüsünü ayarlayın

Durable Task Scheduler emülatörü, Azure aboneliği olmadan orkestrasyonları test edebilmeniz için yerel bir geliştirme ortamı sağlar. PowerShell Functions barındırıcısı da yerel depolama için Azurite'i gerektirir.

Her iki konteyneri de başlatın:

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

Öykünücü çalıştırıldıktan sonra, düzenlemeleri izlemek için adresindeki http://localhost:8082 Dayanıklı Görev Zamanlayıcı panosuna erişebilirsiniz.

Hızlı başlangıç örneğini çalıştırma

  1. Hello Cities örnek dizinine gidin:

    cd samples/durable-functions/powershell/HelloCities

  2. local.settings.json Dosyanın aşağıdaki yapılandırmayı içerdiğini doğrulayın:

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

  3. İşlev uygulamasını başlatın:

    func start

  4. Ayrı bir terminalde işlev zincirleme düzenlemesini tetikleyin :

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

    Yanıt, düzenleme örneğinin durum URL'lerini içerir. statusQueryGetUri Değeri kopyalayın ve çalıştırarak sonucu denetleyin:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  5. fan-out/fan-in orkestrasyonunu tetikleme:

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

Beklenen çıkış

POST isteği durum URL'lerine sahip bir JSON yanıtı döndürür. Örneğin:

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

statusQueryGetUri sorguladığınızda ve orkestrasyonun runtimeStatus değeri Completed olduğunda, selamlama sonuçlarını output alanında bulabilirsiniz. Zincirleme düzenlemesi şunu döndürür:

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

Fan-out/fan-in orkestrasyonu şunu döndürür:

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

Tip

runtimeStatus, Running veya Pending gösteriyorsa bir an bekleyin ve statusQueryGetUri’ü yeniden sorgulayın.

Orkestrasyon durumunu ve yürütme geçmişini görüntülemek için http://localhost:8082 adresindeki Dayanıklı Görev Zamanlayıcı panosunu açın.

Kodu anlama

Örnek proje, her işlevin kendi alt dizininde bir function.json bağlama dosyası ve bir run.ps1 betiği bulunduğu PowerShell işlev modelini kullanır.

Aktivite işlevi

SayHello etkinliği (SayHello/run.ps1) bir şehir adı alır ve bir selamlama döndürür:

param($city)

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

Orchestrator işlevleri

Zincirleme orkestratör (ChainingOrchestration/run.ps1), üç şehir için SayHello çağrısını sırayla yapar:

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 düzenleyicisi (FanOutFanInOrchestration/run.ps1) etkinlikleri paralel olarak düzenler:

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

İstemci işlevleri

HTTP ile tetiklenen istemci işlevleri her düzenlemeyi başlatır. Örneğin, 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

Configuration

Örnek, depolama altyapısı olarak Durable Task Scheduler öykünücüsünü kullanır. Bu, host.json içinde yapılandırılır:

{
  "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
  }
}

managedDependency ayarı, Dayanıklı İşlevler SDK dahil olmak üzere requirements.psd1'da tanımlanan gerekli PowerShell modüllerini otomatik olarak yükler.

Kaynakları temizle

İşiniz bittiğinde öykünücü kapsayıcılarını durdurun:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Sonraki Adımlar

  • Last updated on