クイック スタート: PowerShell Durable Functions アプリを作成する

Azure Functions の機能である Durable Functions を使用して、PowerShell でステートフル サーバーレス ワークフローを記述します。 このクイック スタートでは、2 つの一般的なオーケストレーション パターンを示すサンプル アプリを複製して実行します。

  • 関数チェーン: アクティビティを順番に呼び出します (東京→シアトル→ロンドン)。
  • ファンアウト/ファンイン: 5 つの都市間でアクティビティを並列で呼び出し、結果を集計します。

最終的には、 Durable Task Scheduler エミュレーターを使用して両方のオーケストレーションがローカルで実行され、ダッシュボードでその状態を表示できるようになります。

  • Hello Cities サンプル プロジェクトを複製して準備します。
  • ローカル開発用に Durable Task Scheduler エミュレーターと Azurite を設定します。
  • 関数アプリを実行し、両方のオーケストレーションをトリガーします。
  • Durable Task Scheduler ダッシュボードでオーケストレーションの状態と出力を確認します。

Prerequisites

Durable Task Scheduler エミュレーターを設定する

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

Tip

エミュレーターが実行されたら、 http://localhost:8082 の Durable Task Scheduler ダッシュボードにアクセスしてオーケストレーションを監視できます。

クイック スタート サンプルを実行する

  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. ファンアウト/ファンイン オーケストレーションをトリガーします：

    $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!"]
}

Tip

runtimeStatus RunningまたはPendingが表示される場合は、しばらく待ってから、statusQueryGetUriをもう一度クエリします。

http://localhost:8082で Durable Task Scheduler ダッシュボードを開き、オーケストレーションの状態と実行履歴を表示します。

コードを理解する

サンプル プロジェクトでは、PowerShell 関数モデルを使用します。各関数は、 function.json バインド ファイルと run.ps1 スクリプトを含む独自のサブディレクトリに存在します。

アクティビティ関数

SayHello アクティビティ (SayHello/run.ps1) は、市区町村の名前を受け取り、あいさつを返します。

param($city)

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

オーケストレーター関数

チェーン オーケストレーター (ChainingOrchestration/run.ps1) は、次の 3 つの都市について 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

コンフィギュレーション

このサンプルでは、ストレージ バックエンドとして Durable Task Scheduler エミュレーターを使用します。 これは、 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

次のステップ

  • Last updated on