使用Azure Function在Azure Data Factory中获取元数据时遇InternalServerError

先排查Azure侧配置问题 #

• 确认Azure Function的系统分配身份已启用，且该身份拥有存储账户testdemo0428的Storage Blob Data Reader权限
• 检查ADF调用函数的参数配置：确保传递的containerName为test2，blobName为f2（注意路径准确性，比如f2是否在根目录，是否包含子文件夹路径）
• 验证Azure Function的网络配置：若存储账户启用防火墙，需确保Function的IP或所属虚拟网络被允许访问

文章代码常见问题及修复 #

原文章代码可能存在适配性问题，针对当前Azure环境调整如下：

1. 身份验证逻辑替换 #

原代码可能使用旧的验证方式，替换为Azure AD身份验证（适配系统身份）：

// 替换原有存储客户端初始化代码
var credential = new DefaultAzureCredential();
var blobServiceClient = new BlobServiceClient(new Uri($"https://{storageAccountName}.blob.core.windows.net"), credential);

2. Blob路径处理优化 #

若f2是文件夹而非单个文件，原代码无法正确遍历内容，需添加文件夹读取逻辑：

var containerClient = blobServiceClient.GetBlobContainerClient(containerName);
if (blobName.EndsWith("/")) // 判断是否为文件夹路径
{
    var blobs = containerClient.GetBlobsByHierarchy(prefix: blobName);
    // 遍历并收集文件夹下所有文件的元数据
    foreach (var blobItem in blobs)
    {
        // 自定义元数据收集逻辑
    }
}
else
{
    var blobClient = containerClient.GetBlobClient(blobName);
    // 处理单个文件的元数据
}

3. 响应格式适配ADF #

确保Function返回的JSON格式符合ADF预期，返回明确的键值对结构：

var properties = blobClient.GetProperties().Value;
return new OkObjectResult(new
{
    BlobName = blobClient.Name,
    Size = properties.ContentLength,
    LastModified = properties.LastModified,
    // 按需添加其他元数据字段
});

总结 #

优先排查Azure侧的权限、网络、参数配置问题；若配置无异常，大概率是原文章代码的身份验证或路径处理逻辑不适配当前环境，按照上述代码调整即可解决。

内容的提问来源于stack exchange，提问作者姚宇澤