Azure Durable Functions：如何根据租户ID传递存储连接字符串

首先明确：C#属性的参数必须是编译时常量，所以你没法把运行时变量x直接传给DurableClientAttribute的ConnectionName属性——属性在编译阶段就会被解析，运行时的变量值无法被属性读取，这是C#语言本身的限制，和Durable Functions无关。

要实现根据租户动态切换存储连接字符串的需求，你可以通过手动构建IDurableOrchestrationClient实例的方式解决，具体步骤如下：

1. 确保依赖包正确安装 #

确认你的项目已安装Microsoft.Azure.WebJobs.Extensions.DurableTask NuGet包（最新稳定版即可），这个包提供了DurableClientFactory用于创建自定义配置的客户端。

2. 手动创建指定连接的客户端 #

通过请求获取租户标识（比如从请求头、Query参数或身份令牌中解析），然后从配置中读取对应租户的存储连接字符串，最后用DurableClientFactory创建客户端实例：

[FunctionName("Function1_HttpStart2")]
public static async Task<HttpResponseMessage> HttpStart2(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestMessage req,
    IConfiguration config,
    DurableClientFactory durableClientFactory,
    ILogger log)
{
    // 从请求中提取租户ID（示例从请求头获取，可根据实际场景调整）
    if (!req.Headers.TryGetValues("X-Tenant-Id", out var tenantIds))
    {
        return req.CreateResponse(HttpStatusCode.BadRequest, "缺少租户ID");
    }
    var tenantId = tenantIds.FirstOrDefault();
    if (string.IsNullOrEmpty(tenantId))
    {
        return req.CreateResponse(HttpStatusCode.BadRequest, "租户ID无效");
    }

    // 从配置中读取对应租户的存储连接字符串
    // 假设配置中键的格式为 "Tenant_{TenantId}_Storage"，可根据实际命名调整
    var connectionStringKey = $"Tenant_{tenantId}_Storage";
    var connectionString = config.GetConnectionString(connectionStringKey);
    if (string.IsNullOrEmpty(connectionString))
    {
        return req.CreateResponse(HttpStatusCode.NotFound, $"未找到租户 {tenantId} 的存储配置");
    }

    // 创建自定义配置的Durable客户端
    var clientOptions = new DurableClientOptions
    {
        // 这里的ConnectionName可任意填写，因为我们直接指定了ConnectionString
        ConnectionName = "TenantSpecificStorage",
        ConnectionString = connectionString
    };

    IDurableOrchestrationClient starter = await durableClientFactory.CreateClientAsync(clientOptions);

    // 后续使用starter执行编排操作，比如启动实例
    var instanceId = await starter.StartNewAsync("YourOrchestratorFunctionName", null);
    log.LogInformation($"已启动编排实例，ID: {instanceId}");

    return starter.CreateCheckStatusResponse(req, instanceId);
}

3. 配置租户对应的连接字符串 #

在local.settings.json（本地调试）或Azure应用服务的配置（生产环境）中，添加各个租户的存储连接字符串，示例：

{
  "ConnectionStrings": {
    "Tenant_A_Storage": "DefaultEndpointsProtocol=https;AccountName=tenantastorage;AccountKey=xxx;EndpointSuffix=core.windows.net",
    "Tenant_B_Storage": "DefaultEndpointsProtocol=https;AccountName=tenantbstorage;AccountKey=yyy;EndpointSuffix=core.windows.net"
  }
}

关于你之前实例化失败的说明 #

你提到尝试实例化DurableOrchestrationClient未被识别，这是因为在新版本的Durable Functions SDK中，DurableOrchestrationClient已被标记为过时，推荐使用IDurableOrchestrationClient接口，并通过DurableClientFactory来创建实例，而非直接new。

内容的提问来源于stack exchange，提问作者user2503078