Azure Event Hub Java绑定：@EventHubOutput是否支持partitionKey及文档问询

别担心，我来帮你理清这个问题——Azure Functions的Java Event Hub输出绑定确实支持指定partitionKey，只是官方文档里的Java示例藏得比较深，容易被忽略～

你可以通过两种方式来设置partitionKey：

• 静态固定分区键：直接在@EventHubOutput注解的参数中指定，适合所有消息都用同一个分区键的场景，示例如下：

  @FunctionName("StaticPartitionKeySender")
  public void sendWithStaticKey(
          @HttpTrigger(name = "req", methods = {HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
          @EventHubOutput(name = "eventHubOutput", eventHubName = "myHub", connection = "EventHubConnStr", partitionKey = "static-fixed-key") OutputBinding<String> output,
          ExecutionContext context) {
      String message = request.getBody().orElse("Default static key message");
      output.setValue(message);
      context.getLogger().info("Message sent with static partition key");
  }
  

• 动态分区键：如果需要根据每条消息的内容动态指定分区键，可以借助OutputBinding的setBindingData方法来传入，这也是更灵活的用法，示例代码：

  @FunctionName("DynamicPartitionKeySender")
  public void sendWithDynamicKey(
          @HttpTrigger(name = "req", methods = {HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
          @EventHubOutput(name = "eventHubOutput", eventHubName = "myHub", connection = "EventHubConnStr") OutputBinding<String> output,
          ExecutionContext context) {
      String message = request.getBody().orElse("Default dynamic key message");
      // 根据消息内容生成动态分区键，这里只是示例，你可以替换成自己的逻辑
      String dynamicKey = "user-" + message.split(":")[0];
      // 设置分区键
      output.setBindingData("partitionKey", dynamicKey);
      output.setValue(message);
      context.getLogger().info("Message sent with dynamic partition key: " + dynamicKey);
  }
  

至于文档的问题，你观察得没错——官方文档确实更多在触发器部分把partitionKey作为元数据来介绍，输出绑定的Java示例相对匮乏，但这个特性是完全支持的。如果还是有疑问，也可以查看EventHubOutput注解的源码，里面会明确标注partitionKey参数的存在。另外建议确保你使用的Azure Functions Java SDK是v3及以上的版本，旧版本可能对这个特性的支持不够完善。

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