빠른 시작: PowerShell Durable Functions 앱 만들기

Azure Functions 기능인 Durable Functions 사용하여 PowerShell에서 상태 저장 서버리스 워크플로를 작성합니다. 이 빠른 시작에서는 두 가지 일반적인 오케스트레이션 패턴을 보여 주는 샘플 앱을 복제하고 실행합니다.

• 함수 연결: 순차적으로 활동을 호출합니다(도쿄 → 시애틀 → 런던).
• 팬아웃/팬인: 5개 도시에서 동시에 활동을 호출한 다음 결과를 집계합니다.

결국 지속성 작업 스케줄러 에뮬레이터를 사용하여 두 오케스트레이션을 로컬로 실행하고 대시보드에서 해당 상태를 볼 수 있습니다.

사전 요구 사항

• PowerShell 7.4 이상이 설치되었습니다.
• Azure Functions Core Tools v4 이상.
• 에뮬레이터 및 Azurite를 실행하기 위한 Docker입니다.
• 빠른 시작 샘플을 사용하도록 지속성 작업 스케줄러 GitHub 리포지토리 를 복제합니다.

지속성 작업 스케줄러 에뮬레이터 설정

Durable Task Scheduler 에뮬레이터는 Azure 구독 없이 오케스트레이션을 테스트할 수 있도록 로컬 개발 환경을 제공합니다. PowerShell Functions 호스트에서도 로컬 스토리지를 위해 Azurite가 필요합니다.

두 컨테이너를 모두 시작합니다.

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

빠른 시작 샘플 실행

1. Hello Cities 샘플 디렉터리로 이동합니다.

   cd samples/durable-functions/powershell/HelloCities
   

2. local.settings.json 파일에 다음 구성이 포함되어 있는지 확인하십시오.

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

3. 함수 앱을 시작합니다.

   func start
   

4. 별도의 터미널에서 함수 체인 오케스트레이션을 트리거합니다.

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

   응답에는 오케스트레이션 인스턴스에 대한 상태 URL이 포함됩니다. statusQueryGetUri 값을 복사하고 실행하여 결과를 확인합니다.

   Invoke-RestMethod -Uri $response.statusQueryGetUri
   

5. fan-out/fan-in 오케스트레이션을 시작합니다:

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

예상 출력

POST 요청은 상태 URL이 있는 JSON 응답을 반환합니다. 다음은 그 예입니다.

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

statusQueryGetUri를 쿼리할 때 오케스트레이션의 runtimeStatus가 Completed이면 output 필드에서 인사말 결과를 찾을 수 있습니다. 체인 오케스트레이션은 다음을 반환합니다.

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

팬아웃/팬인 오케스트레이션은 다음을 반환합니다.

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

지속성 작업 스케줄러 대시보드를 http://localhost:8082 열어 오케스트레이션 상태 및 실행 기록을 봅니다.

코드 이해

샘플 프로젝트는 각 함수가 function.json 바인딩 파일과 run.ps1 스크립트를 포함하는 자체 하위 디렉터리에 있는 PowerShell 함수 모델을 사용합니다.

작업 함수

활동(SayHello)은 SayHello/run.ps1 도시 이름을 사용하고 인사말을 반환합니다.

param($city)

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

오케스트레이터 함수

체이닝 오케스트레이터 (ChainingOrchestration/run.ps1)는 세 도시 각각에 대해 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

팬아웃/팬인 오케스트레이터(FanOutFanInOrchestration/run.ps1)는 다음과 같이 작업을 병렬로 예약합니다.

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

클라이언트 함수

HTTP 트리거 클라이언트 함수는 각 오케스트레이션을 시작합니다. 예를 들어 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

이 샘플에서는 지속성 작업 스케줄러 에뮬레이터를 스토리지 백 엔드로 사용합니다. 이는 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
  }
}

managedDependency 설정은 Durable Functions SDK를 포함하여 requirements.psd1 정의된 필수 PowerShell 모듈을 자동으로 설치합니다.

자원을 정리하세요

완료되면 에뮬레이터 컨테이너를 중지합니다.

docker stop dtsemulator azurite && docker rm dtsemulator azurite

다음 단계

• common Durable Functions 앱 패턴 대해 알아봅니다.
• 독립 실행형 PowerShell SDK 가이드를 검토합니다.
• Durable Functions 스토리지 공급자 대해 알아봅니다.