Durable Functions での関数チェーン - Hello シーケンス サンプル

• クイックスタートの記事を完了していること
• GitHub からサンプル プロジェクトをクローンまたはダウンロードしていること

• クイックスタートの記事を完了していること
• GitHub からサンプル プロジェクトをクローンまたはダウンロードしていること

• クイックスタートの記事を完了していること
• GitHub からサンプル プロジェクトをクローンまたはダウンロードしていること

• クイックスタートの記事を完了していること
• GitHub からサンプル プロジェクトをクローンまたはダウンロードしていること

[FunctionName("E1_HelloSequence")]
public static async Task<List<string>> Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var outputs = new List<string>();

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

    // returns ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
    return outputs;
}

すべての C# オーケストレーション関数は、Microsoft.Azure.WebJobs.Extensions.DurableTask アセンブリにある DurableOrchestrationContext 型のパラメーターを持つ必要があります。 このコンテキスト オブジェクトでは、他のアクティビティ関数を呼び出し、その CallActivityAsync メソッドを使用して入力パラメーターを渡すことができます。

このコードでは、E1_SayHello を異なるパラメーター値で 3 回続けて呼び出します。 各呼び出しの戻り値が outputs 一覧に追加され、それが関数の末尾に返されます。

function.json

Visual Studio Code または Azure Portal を開発に使用する場合は、こちらのオーケストレーター関数の function.json ファイルの内容をご覧ください。 ほとんどの orchestrator function.json ファイルは、このような内容です。

{
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

重要な点は、orchestrationTrigger というバインドの種類です。 すべての orchestrator 機能は、このトリガーの種類を使用する必要があります。

index.js

オーケストレーター関数をこちらに示します。

const df = require("durable-functions");

module.exports = df.orchestrator(function* (context) {
    context.log("Starting chain sample");
    const output = [];
    output.push(yield context.df.callActivity("E1_SayHello", "Tokyo"));
    output.push(yield context.df.callActivity("E1_SayHello", "Seattle"));
    output.push(yield context.df.callActivity("E1_SayHello", "London"));

    return output;
});

すべての JavaScript オーケストレーション関数に、durable-functions module モジュールが含まれている必要があります。 それは、Durable Functions を JavaScript で記述することができるライブラリです。 オーケストレーター関数と他の JavaScript 関数には、次の 3 つの大きな違いがあります。

1. オーケストレーター関数はジェネレーター関数です。
2. この関数は、durable-functions モジュールの orchestrator メソッドの呼び出しにラップされます (ここでは df)。
3. この関数は同期的であることが必要です。 "orchestrator" メソッドによって "context.done" の最終呼び出しが処理されるため、この関数は "値を返す" ことのみを行います。

context オブジェクトには、df 永続的なオーケストレーション コンテキスト オブジェクトが含まれています。このオブジェクトを使用すると、他の アクティビティ 関数を呼び出し、その callActivity メソッドを使用して入力パラメーターを渡すことができます。 このコードでは、異なるパラメーター値で E1_SayHello を 3 回続けて呼び出しています。yield を使用して実行を示すと、非同期アクティビティ関数呼び出しが返されるのを待つ必要があります。 各呼び出しの戻り値が outputs 配列に追加されます。これは、関数の末尾に返されます。

const df = require("durable-functions");

const helloActivityName = "sayHello";

df.app.orchestration("helloSequence", function* (context) {
    context.log("Starting chain sample");

    const output = [];
    output.push(yield context.df.callActivity(helloActivityName, "Tokyo"));
    output.push(yield context.df.callActivity(helloActivityName, "Seattle"));
    output.push(yield context.df.callActivity(helloActivityName, "Cairo"));

    return output;
});

すべての JavaScript オーケストレーション関数に、durable-functions module モジュールが含まれている必要があります。 このモジュールにより、Durable Functions を JavaScript で記述することができます。 V4 ノード プログラミング モデルを使用するには、プレビュー v3.x バージョンの durable-functions をインストールする必要があります。

オーケストレーター関数と他の JavaScript 関数には、次の 2 つの大きな違いがあります。

1. オーケストレーター関数はジェネレーター関数です。
2. この関数は同期的であることが必要です。 関数は単純に 'return' する必要があります。

context オブジェクトには、df 永続的なオーケストレーション コンテキスト オブジェクトが含まれています。このオブジェクトを使用すると、他の アクティビティ 関数を呼び出し、その callActivity メソッドを使用して入力パラメーターを渡すことができます。 このコードでは、異なるパラメーター値で sayHello を 3 回続けて呼び出しています。yield を使用して実行を示すと、非同期アクティビティ関数呼び出しが返されるのを待つ必要があります。 各呼び出しの戻り値が outputs 配列に追加されます。これは、関数の末尾に返されます。

function.json

Visual Studio Code または Azure Portal を開発に使用する場合は、こちらのオーケストレーター関数の function.json ファイルの内容をご覧ください。 ほとんどの orchestrator function.json ファイルは、このような内容です。

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ]
}

重要な点は、orchestrationTrigger というバインドの種類です。 すべての orchestrator 機能は、このトリガーの種類を使用する必要があります。

__init__.py

オーケストレーター関数をこちらに示します。

import azure.functions as func
import azure.durable_functions as df


def orchestrator_function(context: df.DurableOrchestrationContext):
    result1 = yield context.call_activity('E1_SayHello', "Tokyo")
    result2 = yield context.call_activity('E1_SayHello', "Seattle")
    result3 = yield context.call_activity('E1_SayHello', "London")
    return [result1, result2, result3]

main = df.Orchestrator.create(orchestrator_function)

すべての Python オーケストレーション関数に、durable-functions パッケージが含まれている必要があります。 これは、Durable Functions を Python で記述できるようにするライブラリです。 オーケストレーター関数と他の Python 関数には、次の 2 つの大きな違いがあります。

1. オーケストレーター関数はジェネレーター関数です。
2. この "ファイル" では、ファイルの末尾に main = df.Orchestrator.create(<orchestrator function name>) を指定することによって、オーケストレーター関数をオーケストレーターとして登録しています。 これにより、ファイルで宣言されている他のヘルパー関数と区別できます。

context オブジェクトでは、他の "アクティビティ" 関数を呼び出し、その call_activity メソッドを使用して入力パラメーターを渡すことができます。 このコードでは、異なるパラメーター値で E1_SayHello を 3 回続けて呼び出しています。yield を使用して実行を示すと、非同期アクティビティ関数呼び出しが返されるのを待つ必要があります。 各呼び出しの戻り値は関数の末尾に返されます。

[FunctionName("E1_SayHello")]
public static string SayHello([ActivityTrigger] IDurableActivityContext context)
{
    string name = context.GetInput<string>();
    return $"Hello {name}!";
}

アクティビティは、ActivityTrigger 属性を使用します。 指定された IDurableActivityContext を使用して、GetInput<T> を使用した入力値へのアクセスなど、アクティビティ関連のアクションを実行します。

E1_SayHello の実装は、比較的単純な文字列の書式設定操作です。

IDurableActivityContextにバインドする代わりに、アクティビティ関数に渡される型に直接バインドすることができます。 次に例を示します。

[FunctionName("E1_SayHello_DirectInput")]
public static string SayHelloDirectInput([ActivityTrigger] string name)
{
    return $"Hello {name}!";
}

E1_SayHello/function.json

アクティビティ関数 E1_SayHello の function.json ファイルは、E1_HelloSequence のそれに似ていますが、バインドの種類 orchestrationTrigger の代わりにバインドの種類 activityTrigger を使用する点が違います。

{
  "bindings": [
    {
      "name": "name",
      "type": "activityTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

E1_SayHello の実装は、比較的単純な文字列の書式設定操作です。

E1_SayHello/index.js

module.exports = function (context) {
    context.done(null, `Hello ${context.bindings.name}!`);
};

オーケストレーション関数とは異なり、アクティビティ関数には特別な設定は不要です。 オーケストレーター関数によって渡される入力は、activityTrigger バインドという名前で context.bindings オブジェクト (この例では context.bindings.name) に配置されます。 サンプル コードに示すように、バインド名はエクスポートされた関数のパラメーターとして設定し、直接アクセスできます。

sayHello の実装は、比較的単純な文字列の書式設定操作です。

const df = require("durable-functions");

const helloActivityName = "sayHello";

df.app.activity(helloActivityName, {
    handler: function (input) {
        return `Hello ${input}`;
    },
});

オーケストレーション関数とは異なり、アクティビティ関数には特別な設定は不要です。 オーケストレーター関数によって渡される入力は、関数の最初の引数です。 2 番目の引数は呼び出しコンテキストです。この例では使用されていません。

E1_SayHello/function.json

アクティビティ関数 E1_SayHello の function.json ファイルは、E1_HelloSequence のそれに似ていますが、バインドの種類 orchestrationTrigger の代わりにバインドの種類 activityTrigger を使用する点が違います。

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "name",
      "type": "activityTrigger",
      "direction": "in"
    }
  ]
}

E1_SayHello の実装は、比較的単純な文字列の書式設定操作です。

E1_SayHello/__init__.py

def main(name: str) -> str:
    return f"Hello {name}!"

オーケストレーター関数とは異なり、アクティビティ関数には特別な設定は不要です。 オーケストレーター関数によって渡された入力には、関数のパラメーターとして直接アクセスできます。

public static class HttpStart
{
    [FunctionName("HttpStart")]
    public static async Task<HttpResponseMessage> Run(
        [HttpTrigger(AuthorizationLevel.Function, methods: "post", Route = "orchestrators/{functionName}")] HttpRequestMessage req,
        [DurableClient] IDurableClient starter,
        string functionName,
        ILogger log)
    {
        // Function input comes from the request content.
        object eventData = await req.Content.ReadAsAsync<object>();
        string instanceId = await starter.StartNewAsync(functionName, eventData);

        log.LogInformation($"Started orchestration with ID = '{instanceId}'.");

        return starter.CreateCheckStatusResponse(req, instanceId);
    }
}

オーケストレーター操作をするには、関数に DurableClient 入力バインドが含まれている必要があります。 クライアントを使用して、オーケストレーションを開始します。 また、新しいオーケストレーションの状態を確認するための URL を含む HTTP 応答を返すこともできます。

HttpStart/function.json

{
    "bindings": [
      {
        "authLevel": "anonymous",
        "name": "req",
        "type": "httpTrigger",
        "direction": "in",
        "route": "orchestrators/{functionName}",
        "methods": ["post"]
      },
      {
        "name": "$return",
        "type": "http",
        "direction": "out"
      },
      {
        "name": "starter",
        "type": "orchestrationClient",
        "direction": "in"
      }
    ],
    "disabled": false
  }

オーケストレーター操作をするには、関数に durableClient 入力バインドが含まれている必要があります。

HttpStart/index.js

const df = require("durable-functions");

module.exports = async function (context, req) {
    const client = df.getClient(context);
    const instanceId = await client.startNew(req.params.functionName, undefined, req.body);

    context.log(`Started orchestration with ID = '${instanceId}'.`);

    return client.createCheckStatusResponse(context.bindingData.req, instanceId);
};

DurableOrchestrationClient オブジェクトを取得するには、df.getClient を使用します。 クライアントを使用して、オーケストレーションを開始します。 また、新しいオーケストレーションの状態を確認するための URL を含む HTTP 応答を返すこともできます。

const df = require("durable-functions");
const { app } = require("@azure/functions");

app.http("httpStart", {
    route: "orchestrators/{orchestratorName}",
    extraInputs: [df.input.durableClient()],
    handler: async (request, context) => {
        const client = df.getClient(context);
        const body = await request.json();
        const instanceId = await client.startNew(request.params.orchestratorName, { input: body });

        context.log(`Started orchestration with ID = '${instanceId}'.`);

        return client.createCheckStatusResponse(request, instanceId);
    },
});

オーケストレーターを管理および操作するには、関数に durableClient 入力バインディングが必要です。 このバインディングは、関数を登録するときに extraInputs 引数で指定する必要があります。 durableClient 入力は、df.input.durableClient() を呼び出すことによって取得できます。

DurableClient オブジェクトを取得するには、df.getClient を使用します。 クライアントを使用して、オーケストレーションを開始します。 また、新しいオーケストレーションの状態を確認するための URL を含む HTTP 応答を返すこともできます。

HttpStart/function.json

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "anonymous",
      "name": "req",
      "type": "httpTrigger",
      "direction": "in",
      "route": "orchestrators/{functionName}",
      "methods": [
        "post",
        "get"
      ]
    },
    {
      "name": "$return",
      "type": "http",
      "direction": "out"
    },
    {
      "name": "starter",
      "type": "durableClient",
      "direction": "in"
    }
  ]
}

オーケストレーター操作をするには、関数に durableClient 入力バインドが含まれている必要があります。

HttpStart/__init__.py

import logging

import azure.functions as func
import azure.durable_functions as df


async def main(req: func.HttpRequest, starter: str) -> func.HttpResponse:
    client = df.DurableOrchestrationClient(starter)
    instance_id = await client.start_new(req.route_params["functionName"], None, None)

    logging.info(f"Started orchestration with ID = '{instance_id}'.")

    return client.create_check_status_response(req, instance_id)

DurableOrchestrationClient を使用して、Durable Functions クライアントを取得します。 クライアントを使用して、オーケストレーションを開始します。 また、新しいオーケストレーションの状態を確認するための URL を含む HTTP 応答を返すこともできます。