基于.NET Core Azure Function实现Logic App分块大文件传输

一、核心实现思路 #

要让Azure Function向启用分块的Logic App HTTP连接器返回大文件，关键是让函数返回流式响应，依靠ASP.NET Core的自动分块传输机制，无需手动循环发送每个块。Logic App的HTTP连接器启用分块后，会自动处理流式响应的分块接收，规避单次请求的大小限制。

二、C# Azure Function等效实现 #

以下是修正后的完整代码，支持从本地文件或Azure Blob存储读取大文件，并以分块方式返回：

从本地文件读取的实现 #

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Extensions.Logging;
using System.IO;
using System.Threading.Tasks;

namespace AzFuncApp
{
    public class GetChunkedDocument
    {
        private readonly ILogger<GetChunkedDocument> _logger;

        public GetChunkedDocument(ILogger<GetChunkedDocument> log)
        {
            _logger = log;
        }

        [FunctionName("GetChunkedDocument")]
        public async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = null)] HttpRequest req)
        {
            _logger.LogInformation("Processing chunked file request");

            string absFilePath = @"500mb.docx";
            if (!File.Exists(absFilePath))
            {
                _logger.LogError("File not found: {Path}", absFilePath);
                return new NotFoundResult();
            }

            // 打开文件流，设置小缓冲让ASP.NET Core自动处理分块
            var fileStream = new FileStream(absFilePath, FileMode.Open, FileAccess.Read, FileShare.Read, bufferSize: 8192, useAsync: true);
            
            // 返回流式结果，ASP.NET Core会自动启用分块传输编码
            return new FileStreamResult(fileStream, "application/vnd.openxmlformats-officedocument.wordprocessingml.document")
            {
                EnableRangeProcessing = true // 可选：支持断点续传
            };
        }
    }
}

从Azure Blob存储读取的实现（更贴合你的场景） #

如果文件存储在Azure Blob中，直接从Blob获取流返回，避免本地文件依赖：

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.Storage.Blob;
using Microsoft.Extensions.Logging;
using System.Threading.Tasks;

namespace AzFuncApp
{
    public class GetChunkedBlobDocument
    {
        private readonly ILogger<GetChunkedBlobDocument> _logger;
        private readonly CloudBlobContainer _blobContainer; // 依赖注入Blob容器

        public GetChunkedBlobDocument(ILogger<GetChunkedBlobDocument> log, CloudBlobContainer blobContainer)
        {
            _logger = log;
            _blobContainer = blobContainer;
        }

        [FunctionName("GetChunkedBlobDocument")]
        public async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = null)] HttpRequest req)
        {
            _logger.LogInformation("Processing chunked blob file request");

            string blobName = req.Query["blobName"];
            if (string.IsNullOrEmpty(blobName))
            {
                return new BadRequestObjectResult("Missing blobName query parameter");
            }

            var blob = _blobContainer.GetBlockBlobReference(blobName);
            if (!await blob.ExistsAsync())
            {
                return new NotFoundResult();
            }

            // 获取Blob的流式响应，自动支持分块
            var blobStream = await blob.OpenReadAsync();
            return new FileStreamResult(blobStream, blob.Properties.ContentType)
            {
                EnableRangeProcessing = true
            };
        }
    }
}

三、关于替代服务器部署的问题 #

• 普通Azure Function完全可用：HTTP触发的Azure Function可直接替代传统服务器，处理分块请求和流式响应，无需额外配置，确保函数运行时版本为.NET Core 6+即可。
• Durable Function的适用场景：如果需要复杂分块逻辑（比如断点续传进度跟踪、多文件分块合并、异步分块生成），可使用Durable Function；但对于简单的大文件分块返回，普通HTTP Function更轻量高效。

关键说明 #

1. 无需手动循环发送块：FileStreamResult会让ASP.NET Core自动处理分块传输，Logic App分块连接器会自动接收每个块，规避单次请求大小限制。
2. 启用EnableRangeProcessing可支持断点续传，让Logic App能请求文件特定部分，优化传输效率。
3. 调整函数内存配置：对于大文件，建议将函数内存配置设为1GB以上，避免内存不足问题。

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