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

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

  • 関数チェーン: アクティビティを順番に呼び出します (東京→シアトル→ロンドン)。

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

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

Prerequisites

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

Durable Task Scheduler エミュレーターは、Azure サブスクリプションなしでオーケストレーションをテストできるように、ローカル開発環境を提供します。 .NET 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/dotnet/HelloCities/http

  2. エミュレーター構成で local.settings.json ファイルを作成します。

    {
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
    "DURABLE_TASK_SERVICE_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None",
    "TASKHUB_NAME": "default"
  }
}

  3. プロジェクトをビルドします。

    dotnet build

  4. 関数アプリを起動します。

    func start

  5. 別のターミナルで、オーケストレーションをトリガーします。

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

    応答には、オーケストレーション インスタンスの状態 URL が含まれています。 statusQueryGetUri値をコピーして実行し、結果を確認します。

    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": "DurableFunctionsOrchestrationCSharp1",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
}

Tip

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

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

コードを理解する

DurableFunctionsOrchestrationCSharp1.cs のサンプル プロジェクトには、Durable Functions アプリに必要な 3 つの関数の種類がすべて含まれています。

アクティビティ関数

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

[Function(nameof(SayHello))]
public static string SayHello([ActivityTrigger] string name, FunctionContext executionContext)
{
    ILogger logger = executionContext.GetLogger("SayHello");
    logger.LogInformation("Saying hello to {name}.", name);
    return $"Hello {name}!";
}

オーケストレーター関数

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

[Function(nameof(DurableFunctionsOrchestrationCSharp1))]
public static async Task<List<string>> RunOrchestrator(
    [OrchestrationTrigger] TaskOrchestrationContext context)
{
    ILogger logger = context.CreateReplaySafeLogger(nameof(DurableFunctionsOrchestrationCSharp1));
    logger.LogInformation("Saying hello.");
    var outputs = new List<string>();

    outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "Tokyo"));
    outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "Seattle"));
    outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "London"));

    return outputs;
}

クライアント関数

HTTP によってトリガーされるクライアント関数は、オーケストレーションを開始します。

[Function("DurableFunctionsOrchestrationCSharp1_HttpStart")]
public static async Task<HttpResponseData> HttpStart(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req,
    [DurableClient] DurableTaskClient client,
    FunctionContext executionContext)
{
    ILogger logger = executionContext.GetLogger("DurableFunctionsOrchestrationCSharp1_HttpStart");
    string instanceId = await client.ScheduleNewOrchestrationInstanceAsync(
        nameof(DurableFunctionsOrchestrationCSharp1));

    logger.LogInformation("Started orchestration with ID = '{instanceId}'.", instanceId);
    return await client.CreateCheckStatusResponseAsync(req, instanceId);
}

コンフィギュレーション

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

{
  "version": "2.0",
  "extensions": {
    "durableTask": {
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SERVICE_CONNECTION_STRING"
      },
      "hubName": "%TASKHUB_NAME%"
    }
  }
}

エミュレーターの接続文字列とタスク ハブの名前は、local.settings.json で設定されます。

{
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
    "DURABLE_TASK_SERVICE_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None",
    "TASKHUB_NAME": "default"
  }
}

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

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

docker stop dtsemulator azurite && docker rm dtsemulator azurite

次のステップ

  • Last updated on