Azure Function绑定类型咨询：Stream Analytics作业与HttpTrigger

我来帮你梳理这两个Azure Functions相关的问题，给出清晰的解答：

当Azure Stream Analytics作业和Azure Functions集成时，主要用到以下几类绑定，覆盖不同的交互场景：

• HttpTrigger：这是最核心的绑定类型。不管是把Stream Analytics的处理结果输出到Function，还是用Function作为Stream Analytics的自定义UDF（用户定义函数），都需要用HttpTrigger——因为Stream Analytics是通过HTTP POST请求来调用Function的，Function必须通过这个绑定接收请求并处理数据。
• Blob Storage绑定（输入/输出）：如果Stream Analytics把输出数据写入Blob存储，你可以给Function配置BlobTrigger绑定，监听Blob的创建或更新事件，自动触发Function处理这些数据；反过来，Function也能通过Blob输入绑定，读取Stream Analytics需要的数据源文件。
• Event Hub绑定（输入/输出）：如果Stream Analytics从Event Hub读取输入数据，Function可以用EventHubTrigger绑定直接消费同一Event Hub的数据流；要是Stream Analytics把输出写入Event Hub，Function同样能通过EventHubTrigger来处理这些实时数据。

针对你用的Visual Studio 2017（15.5.5版本）的Azure Function模板，默认生成的Run方法用了HttpRequestMessage和TraceWriter，但其实HttpTrigger还支持很多其他参数类型，下面是常用的几种：

直接绑定请求内容到简单类型/自定义对象 #

• string：如果请求体是纯文本，直接把参数类型设为string就行，Function会自动把请求体内容绑定到这个参数，示例代码：

  public static async Task<IActionResult> Run(string requestBody, TraceWriter log)
  {
      log.Info($"收到请求内容：{requestBody}");
      return new OkObjectResult("处理成功");
  }
  

• 自定义POCO类：如果请求体是JSON格式，你可以先定义一个和JSON结构匹配的实体类，然后把参数类型设为这个类，Function会自动完成JSON反序列化，示例：

  public class UserRequest
  {
      public string Name { get; set; }
      public int Age { get; set; }
  }
  
  public static async Task<IActionResult> Run(UserRequest request, TraceWriter log)
  {
      log.Info($"收到用户信息：{request.Name}，年龄：{request.Age}");
      return new OkObjectResult(request);
  }
  

日志与上下文相关类型 #

• ILogger：虽然你的VS版本默认用TraceWriter，但如果是Azure Functions v2及以上 runtime（可以通过升级项目SDK支持），可以用ILogger替代TraceWriter，它是更符合.NET标准的日志组件，示例：

  public static async Task<IActionResult> Run(HttpRequest req, ILogger log)
  {
      log.LogInformation("开始处理HTTP请求");
      return new OkObjectResult("处理成功");
  }
  

  注意：如果你的项目是基于.NET Framework的Functions v1，需要通过NuGet安装兼容的Microsoft.Extensions.Logging包才能使用ILogger。
• HttpRequest：和默认的HttpRequestMessage不同，HttpRequest是更轻量化的请求对象，在Functions v2+中支持，能更简洁地读取查询参数、请求头等，示例：

  public static async Task<IActionResult> Run(HttpRequest req, TraceWriter log)
  {
      string name = req.Query["name"];
      return new OkObjectResult($"你好，{name}");
  }
  

• ClaimsPrincipal：如果请求带有身份验证信息（比如Azure AD OAuth），可以绑定到ClaimsPrincipal参数，直接获取当前用户的身份详情：

  public static async Task<IActionResult> Run(HttpRequest req, ClaimsPrincipal user, TraceWriter log)
  {
      log.Info($"当前认证用户：{user.Identity.Name}");
      return new OkObjectResult($"你好，{user.Identity.Name}");
  }
  

流处理相关类型 #

• Stream：如果需要直接处理请求体的原始流数据，可以把参数类型设为Stream，适合处理大文件或二进制数据：

  public static async Task<IActionResult> Run(Stream requestBody, TraceWriter log)
  {
      using (var reader = new StreamReader(requestBody))
      {
          string content = await reader.ReadToEndAsync();
          log.Info($"收到流内容：{content}");
          return new OkObjectResult(content);
      }
  }
  

需要注意的是，VS2017 15.5.5默认的模板可能是基于Functions v1 runtime（.NET Framework），部分v2的特性（比如HttpRequest参数）需要你手动升级项目的Azure Functions SDK版本，或者在创建项目时选择对应的runtime版本。

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