持久任务计划程序的大型有效负载支持（预览版）

启用该功能之前，请确保应用：

• 使用 .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 Functions API。 运行时会在 context.GetInput<T>() 之前自动解析 Blob 引用，然后 context.CallActivityAsync<T>() 返回数据。

默认情况下，扩展会将外部化有效负载写入由durabletask-payloads配置的存储帐户中的AzureWebJobsStorage容器。

有关端到端示例，请参阅以下示例：

• Durable Functions大型有效负载示例
• Durable Functions 大型负载扇出 / 扇入示例

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

安装 Azure Blob 有效负载扩展包：

dotnet add package Microsoft.DurableTask.Extensions.AzureBlobPayloads

为持久任务计划程序安装 Azure 托管客户端和辅助角色包：

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

注册外部化有效负载存储，选择阈值，并在客户端和工作器上启用有效负载处理。

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，并且可以有选择性地以用户分配的托管标识为目标。

保留 ThresholdBytes 不高于 1,048,576 字节。 该示例使用 900,000 字节，以便在负载接近 1 兆字节调度器消息界限之前卸载负载。

有关端到端.NET示例，请参阅 Durable Task SDK 大型有效负载示例。

适用于 .NET 和 Python 持久任务 SDK 的持久任务计划程序大负载支持可用。

适用于 .NET 和 Python 持久任务 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 而不是存储连接字符串，请在 account_url 中设置 credential 和 BlobPayloadStoreOptions。 示例使用 DefaultAzureCredential。

保留 threshold_bytes 不高于 1,048,576 字节。 当前示例使用 1,024 字节，以便在本地运行期间看到有效负载外部化发生。

有关端到端Python示例，请参阅 持久性任务 SDK 大负载Python示例。

适用于 .NET 和 Python 持久任务 SDK 的持久任务计划程序大负载支持可用。

该 ACTIVITY_COUNT 设置仅由 LargePayloadFanOutFanIn 示例使用。 LargePayload 往返示例不会读取它。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

持久任务计划程序对大型有效负载的支持仅适用于 .NET 隔离的 C# Durable Functions 应用。

如果 PAYLOAD_STORAGE_CONNECTION_STRING 没有设置且提供了 PAYLOAD_STORAGE_ACCOUNT_URI，则示例使用 DefaultAzureCredential。 如果需要特定的用户分配身份，请设置PAYLOAD_STORAGE_MANAGED_IDENTITY_CLIENT_ID或AZURE_CLIENT_ID。

显示了.NET和Python的示例设置。

显示了.NET和Python的示例设置。

Python 示例在代码中使用 threshold_bytes 设置 BlobPayloadStoreOptions。

显示了.NET和Python的示例设置。