Durable Task Scheduler を使用した大規模なペイロードのサポート (プレビュー)

この機能を有効にする前に、アプリが以下の条件を満たしていることを確認してください。

• .NET分離ワーカーを使用します。
• Microsoft.Azure.Functions.Worker.Extensions.DurableTask および Microsoft.Azure.Functions.Worker.Extensions.DurableTask.AzureManaged を参照します。
• 外部化されたペイロードを保持するストレージ アカウントに AzureWebJobsStorage を設定します。
• ターゲット スケジューラとタスク ハブの DTS_CONNECTION_STRING と TASKHUB_NAME を設定します。

次に、host.jsonで大きなペイロード ストレージ を 有効にします。

{
  "version": "2.0",
  "extensions": {
    "durableTask": {
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DTS_CONNECTION_STRING",
        "payloadStorageEnabled": true,
        "payloadStorageThresholdBytes": 900000
      },
      "hubName": "%TASKHUB_NAME%"
    }
  }
}

制限に近づく前にランタイムがペイロードを外部化するように、 payloadStorageThresholdBytes Durable Task Scheduler のメッセージ サイズ境界の下に設定します。

オーケストレーターとアクティビティ コードで標準のDurable Functions API を使用します。 ランタイムは、context.GetInput<T>() および context.CallActivityAsync<T>() にデータを返す前に BLOB 参照を自動的に解決します。

既定では、拡張機能は、durabletask-payloadsによって構成されたストレージ アカウント内のAzureWebJobsStorage コンテナーに外部化されたペイロードを書き込みます。

エンド ツー エンドの例については、次のサンプルを参照してください。

• Durable Functions大きなペイロードのサンプル
• Durable Functionsの大きなペイロードのファンアウト/ファンインのサンプル

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Azure BLOB ペイロード拡張機能パッケージをインストールします。

dotnet add package Microsoft.DurableTask.Extensions.AzureBlobPayloads

Durable Task Scheduler 用の Azure Managed クライアント パッケージと worker パッケージをインストールします。

dotnet add package Microsoft.DurableTask.Client.AzureManaged
dotnet add package Microsoft.DurableTask.Worker.AzureManaged

外部化されたペイロード ストアを登録し、しきい値を選択し、クライアントと worker の両方でペイロード解決を有効にします。

builder.Services.AddExternalizedPayloadStore(options =>
{
    options.ThresholdBytes = 900_000;
    options.ConnectionString = builder.Configuration["PAYLOAD_STORAGE_CONNECTION_STRING"]
        ?? "UseDevelopmentStorage=true";
    options.ContainerName = "durabletask-payloads";
});

builder.Services.AddDurableTaskClient(client =>
{
    client.UseDurableTaskScheduler(schedulerConnectionString);
    client.UseExternalizedPayloads();
});

builder.Services.AddDurableTaskWorker(worker =>
{
    worker.UseDurableTaskScheduler(schedulerConnectionString);
    worker.UseExternalizedPayloads();
});

ストレージ接続文字列の代わりにMicrosoft Entra IDを使用する場合は、options.AccountUri と options.Credential を設定します。 このサンプルでは、 DefaultAzureCredential を使用し、必要に応じてユーザー割り当てマネージド ID をターゲットにすることができます。

ThresholdBytesは1,048,576バイト以下にしてください。 サンプルでは 900,000 バイトを使用するため、ペイロードは 1 MiB スケジューラ メッセージ境界に近づく前にオフロードされます。

エンドツーエンドの.NETの例については、Durable Task SDK の大規模なペイロード サンプルを参照してください。

Durable Task Scheduler を使用した大規模なペイロードのサポートは、.NETおよび Python Durable Task SDK で利用できます。

Durable Task Scheduler を使用した大規模なペイロードのサポートは、.NETおよび Python Durable Task SDK で利用できます。

Azure BLOB ペイロード拡張機能と Azure マネージド トランスポート パッケージを使用して、Python SDK をインストールします。

pip install durabletask[azure-blob-payloads] durabletask-azuremanaged

BlobPayloadStoreを作成し、しきい値を選択し、ワーカーとクライアントの両方に同じストアを渡します。

from durabletask.azuremanaged.client import DurableTaskSchedulerClient
from durabletask.azuremanaged.worker import DurableTaskSchedulerWorker
from durabletask.extensions.azure_blob_payloads import BlobPayloadStore, BlobPayloadStoreOptions

store = BlobPayloadStore(BlobPayloadStoreOptions(
    connection_string=storage_connection_string,
    container_name="durabletask-payloads",
    threshold_bytes=900_000,
))

with DurableTaskSchedulerWorker(
    host_address=endpoint,
    secure_channel=secure_channel,
    taskhub=taskhub_name,
    token_credential=credential,
    payload_store=store,
) as worker:
    worker.start()

    client = DurableTaskSchedulerClient(
        host_address=endpoint,
        secure_channel=secure_channel,
        taskhub=taskhub_name,
        token_credential=credential,
        payload_store=store,
    )

ストレージ 接続文字列 の代わりに Microsoft Entra ID を使用する場合は、BlobPayloadStoreOptions において account_url と credential を設定します。 このサンプルでは、 DefaultAzureCredentialを使用します。

threshold_bytesは1,048,576バイト以下にしてください。 現在のサンプルでは 1,024 バイトを使用しているため、ローカル実行中にペイロードの外部化が行われるのを確認できます。

エンドツーエンドのPythonの例については、Durable Task SDK の大きなペイロードPythonサンプルを参照してください。

Durable Task Scheduler を使用した大規模なペイロードのサポートは、.NETおよび Python Durable Task SDK で利用できます。

ACTIVITY_COUNT設定は、LargePayloadFanOutFanInサンプルでのみ使用されます。 LargePayload ラウンドトリップ サンプルでは、読み取ることができません。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

Durable Task Scheduler での大規模なペイロードのサポートは、分離された C# Durable Functions アプリ.NETでのみ使用できます。

PAYLOAD_STORAGE_CONNECTION_STRINGが設定されておらず、PAYLOAD_STORAGE_ACCOUNT_URIが指定されている場合、サンプルではDefaultAzureCredentialを使用します。 特定のユーザー割り当て ID が必要な場合は、 PAYLOAD_STORAGE_MANAGED_IDENTITY_CLIENT_ID または AZURE_CLIENT_IDを設定します。

.NETとPythonのサンプル設定が表示されます。

.NETとPythonのサンプル設定が表示されます。

Pythonサンプルでは、threshold_bytes を使用してコードに BlobPayloadStoreOptions を設定します。

.NETとPythonのサンプル設定が表示されます。