Python Azure函数如何正确配置EventHub命令式输出绑定

函数添加输出绑定后无法正常触发，是配置错误+用法不符合运行时规范导致的：

• 第三个输出绑定的属性名大小写错误：配置中写的是eventHubname，正确驼峰格式属性名为eventHubName。Azure Functions绑定解析逻辑严格区分大小写，属性名不匹配会直接导致整个绑定配置加载失败，函数启动阶段就会抛出异常，自然无法被EventHub事件触发。
• function.json中connection字段填写的是函数应用配置项的名称，不能直接把连接字符串硬编码写在配置文件里。如果对应配置项不存在、配置的连接字符串没有目标EventHub的操作权限，也会导致绑定初始化失败。
• Python进程内模型下，无类型的func.Out参数声明不合法，必须指定输出值对应的泛型类型，否则函数运行时加载参数签名时会抛出类型错误。

1. 修正function.json配置 #

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "event",
      "type": "eventHubTrigger",
      "direction": "in",
      "eventHubName": "A",
      "consumerGroup": "myConsumerGroup",
      "connection": "aConnectionString"
    },
    {
      "type": "eventHub",
      "name": "B",
      "eventHubName": "B",
      "connection": "bConnectionString",
      "direction": "out"
    },
    {
      "type": "eventHub",
      "name": "C",
      "eventHubName": "C",
      "connection": "cConnectionString",
      "direction": "out"
    }
  ]
}

配置检查要点：提前在函数应用的「应用设置」中添加aConnectionString、bConnectionString、cConnectionString三个配置项，值分别为对应EventHub的连接字符串，且连接字符串要具备监听/发送消息的对应权限。

2. 修正Python函数代码 #

import logging
import azure.functions as func

def main(event: func.EventHubEvent, B: func.Out[str], C: func.Out[str]):
    logging.info('########################################')
    logging.info('Function triggered to process a message:')
    logging.info(f'  EnqueuedTimeUtc = {event.enqueued_time}')
    logging.info(f'  SequenceNumber = {event.sequence_number}')
    logging.info(f'  Offset = {event.offset}')
    logging.info('----------------------------------------')
    logging.info('  Metadata: ')
    for key in event.metadata:
        logging.info(f'    key {key} = {event.metadata[key]}')
    message_body = event.get_body().decode()
    logging.info(f'  Body = {message_body}')
    logging.info('----------------------------------------')

    # 替换为实际的消息路由判断逻辑
    if "routeToB" in message_body:
        B.set(message_body)
    elif "routeToC" in message_body:
        C.set(message_body)
    
    logging.info('Message routing completed')
    logging.info('########################################')

• 命令式输出绑定时，func.Out必须指定泛型类型：发送字符串消息用func.Out[str]，发送原始字节消息用func.Out[bytes]。
• 仅当需要向对应EventHub发送消息时，才调用对应输出参数的.set()方法传入消息内容，不需要发送的输出不要调用.set()即可，不会产生空消息。
• 如果仍存在启动异常，可以直接查看函数应用的日志流，报错信息会明确提示具体的绑定配置错误位置。

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