Azure Event Hub触发函数对接Flutter Web：API端点方案咨询

我已创建Event Hub并完成与IoT Hub的消息路由，当前Azure Function的Event Hub触发器可正常运行，且能在监控模块中查看数据。现需将这些数据传输至Flutter Web应用，因此需要一个可供Web应用调用的API端点，但目前仅拥有HTTP触发器的URL，Event Hub触发器并无对应URL。请问我是否需要调用现有URL，还是改用HTTP触发器？哪种方案是最优选择？是否有其他替代方案？

import azure.functions as func
import logging
import json

app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)

# @app.route(route="http_trigger")
# def http_trigger(req: func.HttpRequest) -> func.HttpResponse:
#     logging.info('Python HTTP trigger function processed a request.')

#     name = req.params.get('name')
#     if not name:
#         try:
#             req_body = req.get_json()
#         except ValueError:
#             pass
#         else:
#             name = req_body.get('name')
#     if name:
#         return func.HttpResponse(f"Hello, {name}. This HTTP triggered function executed successfully.")
#     else:
#         return func.HttpResponse(
#              "This HTTP triggered function executed successfully. Pass a name in the query string or in the request body for a personalized response.",
#              status_code=200
#         )


@app.event_hub_message_trigger(arg_name="azeventhub", event_hub_name="eventhubiot",
                               connection="AZHUB_events_IOTHUB") 
def eventhub_trigger(azeventhub: func.EventHubEvent)-> func.HttpResponse:
    logging.info('Python EventHub trigger processed an event: %s',
                azeventhub.get_body().decode('utf-8'))
    device_id = None
    temperature = None

    for line in azeventhub.get_body().decode('utf-8').split('\n'):
        if line.strip():
            key, value = line.split(':')
            if key.strip() == 'device_id':
                device_id = value.strip()
            elif key.strip() == 'temperature':
                temperature = value.strip()

    response_body = json.dumps({"device_id": device_id, "temperature": temperature})

    return func.HttpResponse(response_body, status_code=200, mimetype='application/json')

注：上述代码中被注释的是之前创建的HTTP触发器，使用内置端点读取数据运行正常。

核心前提 #

Event Hub触发器是被动事件驱动型函数，没有对外可调用的HTTP URL，它仅能在Event Hub有新消息时自动触发执行，无法被Flutter Web主动调用获取数据。

1. 是否调用现有HTTP触发器URL/改用HTTP触发器？ #

• 不能直接将Event Hub触发器改为HTTP触发器：HTTP触发器是主动调用模式，若在其中编写拉取Event Hub消息的逻辑，会违背Serverless异步处理的设计原则，且效率低下、难以维护。
• 现有HTTP触发器的URL可以复用，但需要调整架构：Event Hub触发器负责接收IoT数据并将其存储到中间存储服务（如Azure Cosmos DB、Redis、SQL数据库），HTTP触发器则负责从存储服务中读取数据并返回给Flutter Web。

2. 最优方案 #

推荐采用职责分离的分层架构：

IoT Hub → Event Hub → Azure Function（Event Hub触发器） → 中间存储服务 → Azure Function（HTTP触发器） → Flutter Web

• 逻辑拆分：Event Hub触发器专注于异步接收、解析IoT设备数据，并将数据持久化到存储；HTTP触发器专注于响应Web应用的请求，从存储中读取最新或历史数据返回。
• 优势：符合Serverless最佳实践，异步处理和同步查询解耦，保证系统扩展性和稳定性，同时满足Flutter Web按需获取数据的需求。

3. 其他替代方案 #

• Azure SignalR Service实时推送：若Flutter Web需要实时获取数据，可在Event Hub触发器接收数据后，通过SignalR主动将数据推送给Web端，无需Web应用轮询HTTP接口，适合实时监控场景。
• Azure Stream Analytics：将Event Hub中的数据通过Stream Analytics进行实时处理，输出到Blob Storage或直接提供查询接口，适合需要批量分析、历史数据查询的场景。
• （不推荐）Flutter Web直接连接Event Hub：虽然可以通过Event Hub SDK实现，但需要处理跨域、权限认证等问题，安全性和复杂度较高，不适合生产环境。

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