如何不使用Blob存储容器接收Azure Event Hub事件并设置触发器下载消息？

一、不依赖Blob存储接收Event Hub事件 #

你可以通过以下几种方式直接消费Event Hub中的事件，无需借助Blob存储：

1. 使用官方SDK直接消费 #

各大主流语言（.NET、Python、Java等）都有Azure Event Hub的官方SDK，你可以编写自定义代码创建事件处理器，直接从Event Hub读取事件：

• Python示例：

  from azure.eventhub import EventHubConsumerClient
  
  CONNECTION_STR = "你的Event Hub连接字符串"
  EVENT_HUB_NAME = "你的Event Hub名称"
  CONSUMER_GROUP = "$Default"
  
  def on_event(partition_context, event):
      # 处理接收到的事件数据
      print(f"从分区 {partition_context.partition_id} 收到事件: {event.body_as_str()}")
      # 手动记录消费位置（可选，重启后可从该位置继续消费）
      partition_context.update_checkpoint(event)
  
  client = EventHubConsumerClient.from_connection_string(
      CONNECTION_STR, CONSUMER_GROUP, eventhub_name=EVENT_HUB_NAME
  )
  
  with client:
      client.receive(on_event=on_event, starting_position="-1")
  

  消费位置（checkpoint）可选择保存在本地文件、数据库或Azure Table Storage中，也可以暂时不持久化（但重启后会重新消费所有事件）。

2. 使用Azure Functions Event Hub触发器（无Blob存储） #

Azure Functions的Event Hub触发器默认用Blob存储保存checkpoint，但你可以修改配置，将checkpoint存储到Azure Table Storage，或者跳过持久化：

• 在函数的host.json中配置checkpoint存储：

  {
    "extensions": {
      "eventHubs": {
        "checkpointStore": {
          "type": "AzureTableStorage",
          "connectionString": "你的Table Storage连接字符串",
          "tableName": "eventhubcheckpoints"
        }
      }
    }
  }
  

  配置完成后，函数会在有新事件时自动触发，直接读取事件数据，无需Blob存储介入。

二、设置事件触发器自动下载消息数据 #

完全可以实现新消息发布时自动触发下载，推荐以下两种方案：

1. Azure Functions Event Hub触发器 #

创建Event Hub触发的Azure Function，每次Event Hub有新消息时函数自动执行，你可在代码中处理消息数据，比如保存到本地文件、FTP服务器或其他存储服务：

• C#函数示例：

  [FunctionName("EventHubDownloadTrigger")]
  public static void Run([EventHubTrigger("你的Event Hub名称", Connection = "EventHubConnectionString", ConsumerGroup = "$Default")] EventData[] events, ILogger log)
  {
      foreach (var eventData in events)
      {
          string message = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);
          log.LogInformation($"收到待下载消息: {message}");
          // 写入本地文件完成下载
          File.WriteAllText(@"C:\EventHubDownloads\new_message.txt", message);
      }
  }
  

2. Azure Logic Apps（或Power Automate） #

用Logic Apps的Azure Event Hub触发器，检测到新消息后触发后续动作，比如将消息内容保存到OneDrive、SharePoint或FTP服务器，实现无代码自动"下载"，通过可视化界面配置即可完成。

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