Azure中用Function App/Logic App将存储账户JSON文件发送至Event Hub的最优方案咨询

两种方案都能完全实现将Azure存储账户容器中Blob的JSON数据推送至Event Hub的需求，具体选型取决于你的场景复杂度、开发习惯和运维偏好，以下是实战中的经验总结：

Function App 方案 #

• 适合具备代码开发能力的场景，灵活性拉满。通过Blob触发型Function可以直接监听存储容器的Blob创建/更新事件，读取JSON内容后调用Event Hub SDK完成数据推送。
• 极简实现示例（C#）：

using Azure.Messaging.EventHubs;
using Azure.Messaging.EventHubs.Producer;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using System.IO;
using System.Threading.Tasks;

public static class BlobToEventHubFunction
{
    [FunctionName("BlobToEventHub")]
    public static async Task Run(
        [BlobTrigger("target-container/{name}", Connection = "AzureWebJobsStorage")] Stream blobStream,
        string name,
        ILogger log)
    {
        log.LogInformation($"Processing blob: {name}, Size: {blobStream.Length} Bytes");

        // 读取Blob中的JSON内容
        string jsonContent;
        using var reader = new StreamReader(blobStream);
        jsonContent = await reader.ReadToEndAsync();

        // 推送至Event Hub
        var eventHubConnStr = "YourEventHubConnectionString";
        var eventHubName = "YourEventHubName";
        await using var producerClient = new EventHubProducerClient(eventHubConnStr, eventHubName);
        using var eventBatch = await producerClient.CreateBatchAsync();
        eventBatch.TryAdd(new EventData(System.Text.Encoding.UTF8.GetBytes(jsonContent)));
        await producerClient.SendAsync(eventBatch);
    }
}

• 优势：自定义逻辑空间大，可轻松实现JSON复杂转换、数据过滤等操作；成本更低（按执行次数计费，低频次场景下费用几乎可以忽略）；便于集成其他自定义代码逻辑。
• 劣势：需要编写和维护代码，对开发能力有要求；调试和排障需要具备一定的云原生开发经验。

Logic App 方案 #

• 适合无代码/低代码场景，通过可视化拖拽配置即可完成全流程。核心步骤非常清晰：
  • 添加「当Blob被添加或修改时（仅属性）」触发器，监听目标存储容器
  • 添加「获取Blob内容」动作，读取JSON数据
  • 添加「发送事件至Event Hub」动作，完成数据推送
• 优势：无需编写代码，十几分钟就能搭建完成并上线；可视化界面便于调试和监控流程状态；内置大量连接器，后续扩展其他流程（比如数据校验、异常通知）非常方便。
• 劣势：灵活性不如Function App，复杂的JSON处理（比如嵌套结构转换、多条件过滤）需要依赖内置表达式或嵌套调用Azure Functions；成本相对较高（按流程运行次数和步骤计费，高频次场景下成本会显著上升）。

选型建议 #

• 如果需求只是简单的Blob触发+推送Event Hub，没有复杂的中间处理逻辑，优先选Logic App，快速上线且无需代码维护。
• 如果需要对JSON做复杂处理、集成自定义业务逻辑，或者团队具备开发能力且追求成本优化，选Function App更合适。

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