如何在Durable Azure Function中创建SQL连接？Activity Function配置求助

一、替代ConfigurationManager获取应用设置/连接字符串 #

在Azure Functions（包括Durable的Activity Function）里，不推荐使用ConfigurationManager——它是传统.NET Framework的配置方式，和Azure Functions的依赖注入模型适配性不佳。下面两种方法更适合当前场景：

1. 依赖注入IConfiguration（推荐方式） #

如果你的Activity Function是基于类编写的，直接通过构造函数注入IConfiguration即可轻松获取配置：

public class SqlActivityFunctions
{
    private readonly IConfiguration _config;

    // 构造函数注入IConfiguration
    public SqlActivityFunctions(IConfiguration config)
    {
        _config = config;
    }

    [FunctionName("GetDataFromSqlActivity")]
    public DataTable GetDataFromSql([ActivityTrigger] string input)
    {
        // 从配置中读取连接字符串
        string connectionString = _config.GetConnectionString("XYZ");
        // 后续SQL操作逻辑...
    }
}

2. 使用Environment.GetEnvironmentVariable（兼容静态函数） #

如果你的代码还是静态函数风格，可以通过环境变量获取配置——Azure Functions会自动把应用设置、连接字符串映射为环境变量：

[FunctionName("GetDataFromSqlActivity")]
public static DataTable GetDataFromSql([ActivityTrigger] string input)
{
    // 两种写法都可行：直接用连接字符串名称，或者加上ConnectionStrings前缀
    string connectionString = Environment.GetEnvironmentVariable("XYZ", EnvironmentVariableTarget.Process);
    // 或者：string connectionString = Environment.GetEnvironmentVariable("ConnectionStrings:XYZ", EnvironmentVariableTarget.Process);
    // 后续SQL操作逻辑...
}

二、Durable Azure Function中SQL连接的最佳实践 #

Durable Function的Activity可能被多次调度，所以SQL连接管理要重点关注连接池复用和资源自动释放，避免性能浪费或连接泄漏。

优化后的完整代码示例 #

结合上面的配置获取方式，优化你的SQL操作代码：

public class SqlActivityFunctions
{
    private readonly IConfiguration _config;

    public SqlActivityFunctions(IConfiguration config)
    {
        _config = config;
    }

    [FunctionName("GetDataFromSqlActivity")]
    public DataTable GetDataFromSql([ActivityTrigger] string input)
    {
        DataTable dataTable = new DataTable();
        string connectionString = _config.GetConnectionString("XYZ");
        
        // 使用using语句自动管理资源，确保连接被释放回连接池
        using (SqlConnection myConnection = new SqlConnection(connectionString))
        {
            string query = "SELECT * FROM TableName";
            using (SqlCommand oCmd = new SqlCommand(query, myConnection))
            {
                myConnection.Open();
                using (SqlDataAdapter da = new SqlDataAdapter(oCmd))
                {
                    da.Fill(dataTable);
                }
                // 无需手动调用Close()，using块结束时会自动释放连接
            }
        }
        return dataTable;
    }
}

关键注意事项： #

• 不要在Orchestrator函数中直接操作SQL：Orchestrator是重入的，且不允许执行IO操作，所有数据库逻辑必须放在Activity Function中。
• 依赖连接池提升性能：只要使用相同的连接字符串，Azure Functions会自动维护连接池，后续请求会复用已有连接，无需每次创建新连接。
• 避免手动管理资源：using语句会自动处理SqlConnection、SqlCommand等资源的释放，比手动调用Close()或Dispose()更可靠。

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