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

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

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

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

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

Prerequisites

Node.js 18 以上がインストールされています。
Azure Functions Core Tools v4 以降。
エミュレーターと Azurite を実行するための Docker。
クイックスタートサンプルを使用するには、Durable Task Scheduler GitHub リポジトリを複製します。

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

Durable Task Scheduler エミュレーターは、Azure サブスクリプションなしでオーケストレーションをテストできるように、ローカル開発環境を提供します。 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 ダッシュボードにアクセスしてオーケストレーションを監視できます。

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

Hello Cities サンプルディレクトリに移動します。
```
cd samples/durable-functions/javascript/HelloCities
```
依存関係をインストールします。
```
npm install
```

local.settings.json ファイルに次の構成が含まれていることを確認します。

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

関数アプリを起動します。
```
func start
```
別のターミナルで、関数チェーンのオーケストレーションを開始します:
```
$response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartChaining
$response
```
応答には、オーケストレーションインスタンスの状態 URL が含まれています。 statusQueryGetUri値をコピーして実行し、結果を確認します。
```
Invoke-RestMethod -Uri $response.statusQueryGetUri
```

ファンアウト/ファンイン オーケストレーションを開始します:

$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 ダッシュボードを開き、オーケストレーションの状態と実行履歴を表示します。

コードを理解する

このサンプルでは、Node.js v4 プログラミングモデルを使用します。このモデルでは、すべての関数が 1 つのファイル (src/functions/helloCities.js) で定義されています。

アクティビティ関数

sayHello アクティビティは市区町村名を受け取り、あいさつ文を返します。

df.app.activity("sayHello", {
  handler: (city) => {
    return `Hello ${city}!`;
  },
});

オーケストレーター関数

連鎖オーケストレーターは、3つの都市に対してsayHelloを順番に呼び出します。

df.app.orchestration("chainingOrchestration", function* (context) {
  const outputs = [];
  outputs.push(yield context.df.callActivity("sayHello", "Tokyo"));
  outputs.push(yield context.df.callActivity("sayHello", "Seattle"));
  outputs.push(yield context.df.callActivity("sayHello", "London"));
  return outputs;
});

ファンアウト/ファンインオーケストレーターは、アクティビティを並列にスケジュールします。

df.app.orchestration("fanOutFanInOrchestration", function* (context) {
  const cities = ["Tokyo", "Seattle", "London", "Paris", "Berlin"];

  // Fan-out: schedule all activities in parallel
  const tasks = cities.map((city) => context.df.callActivity("sayHello", city));

  // Fan-in: wait for all to complete
  const results = yield context.df.Task.all(tasks);
  return results;
});

クライアント関数

HTTP によってトリガーされるクライアント関数は、各オーケストレーションを開始します。たとえば、チェーンスターターは次のようになります。

app.http("StartChaining", {
  route: "StartChaining",
  methods: ["POST"],
  authLevel: "anonymous",
  extraInputs: [df.input.durableClient()],
  handler: async (request, context) => {
    const client = df.getClient(context);
    const instanceId = await client.startNew("chainingOrchestration");
    context.log(`Started chaining orchestration with ID = '${instanceId}'.`);
    return client.createCheckStatusResponse(request, instanceId);
  },
});

コンフィギュレーション

このサンプルでは、ストレージバックエンドとして Durable Task Scheduler エミュレーターを使用します。これは、 host.jsonで構成されます。

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "DurableTask.Core": "Warning"
    }
  },
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}

リソースをクリーンアップする

完了したら、エミュレーターコンテナーを停止します。

docker stop dtsemulator azurite && docker rm dtsemulator azurite

次のステップ

common Durable Functions アプリパターンについて説明します。
Durable Functions ストレージプロバイダーについて説明します。

フィードバック

このページはお役に立ちましたか?

Last updated on 2026-06-05