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

3. プロンプトで、次の情報を指定します。

   Prompt	アクション	説明
   関数アプリ プロジェクトの言語を選択してください	[Python] を選択します。	ローカルの Python Functions プロジェクトを作成します。
   バージョンを選択してください	[Azure Functions v4] を選択します。	このオプションは、Core Tools がまだインストールされていない場合にのみ表示されます。 その場合、アプリの初回実行時に Core Tools がインストールされます。
   Python のバージョン	[Python 3.7]、[Python 3.8]、[Python 3.9]、または [Python 3.10] を選択します。	Visual Studio Code は、選択されたバージョンを使用して仮想環境を作成します。
   Select a template for your project's first function (プロジェクトの最初の関数のテンプレートを選択してください)	[後で確認する] を選択します。
   Select how you would like to open your project (プロジェクトを開く方法を選択してください)	[Open in current window] (現在のウィンドウで開く) を選択します。	選択されたフォルダーで Visual Studio Code を開きます。

3. プロンプトで、次の情報を指定します。

   プロンプト	値	説明
   言語を選択する	[Python (プログラミング モデル V2)] を選択します。	V2 プログラミング モデルを使用して、ローカルの Python Functions プロジェクトを作成します。
   バージョンを選択してください	[Azure Functions v4] を選択します。	このオプションは、Core Tools がまだインストールされていない場合にのみ表示されます。 その場合、アプリの初回実行時に Core Tools がインストールされます。
   Python のバージョン	[Python 3.7]、[Python 3.8]、[Python 3.9]、または [Python 3.10] を選択します。	Visual Studio Code は、選択されたバージョンを使用して仮想環境を作成します。
   Select how you would like to open your project (プロジェクトを開く方法を選択してください)	[Open in current window] (現在のウィンドウで開く) を選択します。	選択されたフォルダーで Visual Studio Code を開きます。

オーケストレーター関数

テンプレートを使用して、プロジェクト内に Durable Functions アプリのコードを作成します。

1. コマンド パレットで、入力して [Azure Functions: 関数を作成する] を選択します。

2. プロンプトで、次の情報を指定します。

   Prompt	アクション	説明
   Select a template for your function (関数のテンプレートを選択してください)	[Durable Functions オーケストレーター] を選択します。	Durable Functions アプリのオーケストレーションを作成します。
   Provide a function name (関数名を指定してください)	[HelloOrchestrator] を選択します。	Durable Function の名前。

ここでは、アクティビティ関数を調整するオーケストレーターを追加しました。 HelloOrchestrator/__init__.py を開いて、オーケストレーター関数を確認します。 context.call_activity を呼び出すたびに、Hello という名前のアクティビティ関数が呼び出されます。

次に、参照先の Hello アクティビティ関数を追加します。

アクティビティ関数

1. コマンド パレットで、入力して [Azure Functions: 関数を作成する] を選択します。

2. プロンプトで、次の情報を指定します。

   Prompt	アクション	説明
   Select a template for your function (関数のテンプレートを選択してください)	[Durable Functions のアクティビティ] を選択します。	アクティビティ関数を作成します。
   Provide a function name (関数名を指定してください)	「Hello」と入力します。	アクティビティ関数の名前。

オーケストレーターによって呼び出される Hello アクティビティ関数を追加しました。 Hello/__init__.py を開いて、それが入力として名前を受け取り、あいさつを返すことを確認します。 アクティビティ関数では、データベース呼び出しや計算の実行などのアクションを実行します。

最後に、オーケストレーションを開始する、HTTP によってトリガーされる関数を追加します。

クライアント関数 (HTTP スターター)

1. コマンド パレットで、入力して [Azure Functions: 関数を作成する] を選択します。

2. プロンプトで、次の情報を指定します。

   Prompt	アクション	説明
   Select a template for your function (関数のテンプレートを選択してください)	[Durable Functions HTTP スターター] を選択します。	HTTP スターター関数を作成します。
   Provide a function name (関数名を指定してください)	「DurableFunctionsHttpStart」と入力します。	クライアント関数の名前
   承認レベル	[匿名] を選択します。	デモの目的で、この値を使用すると、認証を使用せずに関数を呼び出すことができます。

オーケストレーションを開始する、HTTP によってトリガーされる関数を追加しました。 DurableFunctionsHttpStart/__init__.py を開いて、client.start_new を使用して新しいオーケストレーションが開始されていることを確認します。 次に、client.create_check_status_response を使用して HTTP 応答が返されます。その応答には、新しいオーケストレーションを監視および管理するために使用できる URL が含まれています。

これで、ローカルで実行して Azure にデプロイできる Durable Functions アプリが作成されました。

必要条件

Python プログラミング モデルのバージョン 2 には、次の最小バージョンが必要です。

• Azure Functions Runtime v4.16 以降
• Azure Functions Core Tools v4.0.5095+ 以降 (ローカルで実行する場合)
• azure-functions-durable v1.2.4+

v2 プログラミング モデルを有効にする

v2 プログラミング モデルを実行するには、次のアプリケーション設定が必要です:

• 名前: AzureWebJobsFeatureFlags
• 値: EnableWorkerIndexing

Azure Functions Core Tools を使ってローカルで実行している場合は、この設定を local.settings.json ファイルに追加します。 Azure で実行している場合は、関連するツールを使用して次の手順を実行します。

az functionapp config appsettings set --name <FUNCTION_APP_NAME> --resource-group <RESOURCE_GROUP_NAME> --settings AzureWebJobsFeatureFlags=EnableWorkerIndexing

Update-AzFunctionAppSetting -Name <FUNCTION_APP_NAME> -ResourceGroupName <RESOURCE_GROUP_NAME> -AppSetting @{"AzureWebJobsFeatureFlags" = "EnableWorkerIndexing"}

これらの 3 つの関数の種類を使用して基本的な Durable Functions アプリを作成するには、function_app.py の内容を次の Python コードに置き換えます。

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

myApp = df.DFApp(http_auth_level=func.AuthLevel.ANONYMOUS)

# An HTTP-triggered function with a Durable Functions client binding
@myApp.route(route="orchestrators/{functionName}")
@myApp.durable_client_input(client_name="client")
async def http_start(req: func.HttpRequest, client):
    function_name = req.route_params.get('functionName')
    instance_id = await client.start_new(function_name)
    response = client.create_check_status_response(req, instance_id)
    return response

# Orchestrator
@myApp.orchestration_trigger(context_name="context")
def hello_orchestrator(context):
    result1 = yield context.call_activity("hello", "Seattle")
    result2 = yield context.call_activity("hello", "Tokyo")
    result3 = yield context.call_activity("hello", "London")

    return [result1, result2, result3]

# Activity
@myApp.activity_trigger(input_name="city")
def hello(city: str):
    return f"Hello {city}"

サンプル内の各関数とその目的の説明については、下の表を参照してください。

1. 関数をテストするには、Hello アクティビティ関数のコード (Hello/__init__.py 内) にブレークポイントを設定します。 F5 キーを押すか、コマンド パレットで [デバッグ: デバッグの開始] を選択して、関数アプリ プロジェクトを開始します。 Core Tools の出力がターミナル パネルに表示されます。

   Note

   デバッグの詳細については、Durable Functions の診断に関する記事を参照してください。

1. 関数をテストするには、hello アクティビティ関数コードにブレークポイントを設定します。 F5 キーを押すか、コマンド パレットで [デバッグ: デバッグの開始] を選択して、関数アプリ プロジェクトを開始します。 Core Tools の出力がターミナル パネルに表示されます。

   Note

   デバッグの詳細については、Durable Functions の診断に関する記事を参照してください。

5. ブラウザーまたは HTTP テスト ツールを使用して URL エンドポイントに HTTP POST 要求を送信します。

   最後のセグメントをオーケストレーター関数の名前 (HelloOrchestrator) に置き換えます。 この URL は http://localhost:7071/api/orchestrators/HelloOrchestrator のようになります。

   応答は、HTTP 関数の最初の結果です。 これによって、持続的オーケストレーションが正常に開始されたことがわかります。 オーケストレーションの最終的な結果はまだ表示されません。 応答には、いくつかの便利な URL が含まれています。 ここでは、オーケストレーションの状態のクエリを実行します。

6. statusQueryGetUri の URL 値をコピーし、それをブラウザーのアドレス バーに貼り付け、要求を実行します。 HTTP テスト ツールを引き続き使用して GET 要求を発行することもできます。

   この要求によって、オーケストレーション インスタンスの状態が照会されます。 これでインスタンスが完了し、Durable Function の出力または結果が含まれていることがわかります。 これは、次の例のようになります。

   {
       "name": "HelloOrchestrator",
       "instanceId": "9a528a9e926f4b46b7d3deaa134b7e8a",
       "runtimeStatus": "Completed",
       "input": null,
       "customStatus": null,
       "output": [
           "Hello Tokyo!",
           "Hello Seattle!",
           "Hello London!"
       ],
       "createdTime": "2020-03-18T21:54:49Z",
       "lastUpdatedTime": "2020-03-18T21:54:54Z"
   }
   

5. ブラウザーまたは HTTP テスト ツールを使用して URL エンドポイントに HTTP POST 要求を送信します。

   最後のセグメントをオーケストレーター関数の名前 (HelloOrchestrator) に置き換えます。 この URL は http://localhost:7071/api/orchestrators/HelloOrchestrator のようになります。

   応答は、HTTP 関数の最初の結果です。 これによって、持続的オーケストレーションが正常に開始されたことがわかります。 オーケストレーションの最終的な結果はまだ表示されません。 応答には、いくつかの便利な URL が含まれています。 ここでは、オーケストレーションの状態のクエリを実行します。

6. statusQueryGetUri の URL 値をコピーし、それをブラウザーのアドレス バーに貼り付け、要求を実行します。 HTTP テスト ツールを引き続き使用して GET 要求を発行することもできます。

   この要求によって、オーケストレーション インスタンスの状態が照会されます。 これでインスタンスが完了し、Durable Function の出力または結果が含まれていることがわかります。 これは、次の例のようになります。

   {
       "name": "hello_orchestrator",
       "instanceId": "9a528a9e926f4b46b7d3deaa134b7e8a",
       "runtimeStatus": "Completed",
       "input": null,
       "customStatus": null,
       "output": [
           "Hello Tokyo!",
           "Hello Seattle!",
           "Hello London!"
       ],
       "createdTime": "2020-03-18T21:54:49Z",
       "lastUpdatedTime": "2020-03-18T21:54:54Z"
   }
   

1. 出力パネルから HTTP トリガーの URL をコピーします。 HTTP によってトリガーされる関数を呼び出す URL は、次の形式である必要があります:

   https://<functionappname>.azurewebsites.net/api/orchestrators/HelloOrchestrator

1. 出力パネルから HTTP トリガーの URL をコピーします。 HTTP によってトリガーされる関数を呼び出す URL は、次の形式である必要があります:

   https://<functionappname>.azurewebsites.net/api/orchestrators/hello_orchestrator