本地Azure Blob Trigger函数触发延迟与积压问题求助

• 使用本地存储模拟器的专用测试容器
  本地开发别直接连接生产Blob存储，改用Azurite（Azure存储模拟器）创建单独的测试容器。每次测试前清空容器内容，或者只放入1-2个用于验证的测试Blob，避免历史数据堆积触发大量任务。
  把local.settings.json里的AzureWebJobsStorage配置指向Azurite，不要用生产存储账户。

• 修改触发器的起始偏移量
  在Blob Trigger特性中指定StartingPosition = StartingPosition.New，让函数只处理启动后的新Blob，直接忽略之前的历史数据。
  示例代码：

  [FunctionName("MyBlobTrigger")]
  public static void Run(
      [BlobTrigger("test-container/{name}", Connection = "AzureWebJobsStorage", StartingPosition = StartingPosition.New)] Stream myBlob,
      string name, ILogger log)
  {
      log.LogInformation($"Processing blob: {name}");
  }
  

  注意：这个设置仅在首次启动函数时生效，若需要重置触发状态，删除本地触发器的checkpoint文件即可——默认存储在Azurite的azure-webjobs-hosts容器中，找到对应函数名的触发器状态文件夹删掉就行。

• 清理本地触发器的Checkpoint数据
  Blob Trigger靠checkpoint记录已处理的Blob，本地运行时这些数据存在Azurite里。不想处理历史数据的话，直接删除对应函数的checkpoint：进入Azurite的azure-webjobs-hosts容器，找到blobtrigger目录，删掉对应函数名的文件夹即可，也可以在启动函数前用脚本清空这块存储。

• 本地测试时严格控制Blob数量
  测试新功能时，别在测试容器里保留大量历史Blob，只放少量测试文件验证功能。测试完成后及时清理容器内容，确保下次启动时只有新的测试Blob会被触发。

• 调整本地函数的批量处理配置
  在host.json里修改Blob Trigger的批量设置，减少每次触发的Blob数量，避免一次性处理大量历史数据：

  {
      "version": "2.0",
      "extensions": {
          "blobs": {
              "maxDegreeOfParallelism": 1,
              "batchSize": 1
          }
      }
  }
  

  这样设置后函数每次只处理一个Blob，降低本地运行负载，缩短测试等待时间。

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