Azure Functions Blob触发器不处理所有Blob

Question

我的存储容器中大约有35k blob文件。其中一些是在部署功能之前的旧版本，一些是在部署功能应用之后的旧版本。

这是我的函数签名

 public async Task Run([BlobTrigger("portal/{filePath}")]Stream blob, Uri uri,
            IDictionary<string, string> metadata, string filePath, ILogger log)
        {
         log.LogInformation($"{filePath}\n Size: {blob.Length} Bytes");

       // rest of the code
        }

我的理解是，这个功能将不断处理所有新旧文件。但是当我在Azure portal上看到那个日志时，这就是发生的事情。

< Li > 2020-01-21t 09:02:56.103[信息]已执行' watch-portal-blob '(成功，Id = 37 CFAF 56-3be 2-4e6f-9e 46-3558389 daf4f) < li>2020-01-21T09:04:33在过去的1分钟内没有新的跟踪。 < li>//更多时间戳 < li>2020-01-21T10:51:34在过去的108分钟内没有新的跟踪。 < li>2020-01-21T10:52:34在过去的109分钟内没有新的跟踪。 < li>2020-01-21T10:53:34在过去的110分钟内没有新的跟踪。 < li>2020-01-21T10:54:34由于超时120分钟，日志流会话已结束。

它随机处理几个文件，然后进入空闲状态，然后在几个小时后再次处理另外20个文件。任何人都可以指出我正确配置 blob 触发器以处理所有现有 blob 以及新的 blob 而不会中断吗？

仅供参考：我的所有 blob 都是简单的 XML 文件，每个文件小于 20 KB。它所做的就是读取XML验证并将其存储在MongoDB中。如果我在本地运行此作业，则在1分钟内至少将处理50个文件，因此应该完成30k个文件。在1月17日星期五，今天1月20日有大约35k文件，仍然有32k文件（新增文件约为2k）。这意味着它在3天内只处理了5k文件。

Answer 1

在引擎盖下，它使用一些事件通知来触发你的功能。这意味着您的旧blobs将不会被触发，除非您在那时更改了某些内容(例如元数据)。

或者，您可以创建一个逻辑应用程序并使用Azure Storage Connector List blobs操作，然后在传递每个blob的工作流中链接您当前的Azure函数。

https://docs.microsoft.com/en-us/connectors/azureblobconnector/#list-blobs

Answer 2

我建议阅读触发器 - blob 收据和触发器 - 轮询

对于您的解决方案，当在blob存储中创建/删除blob时，应该考虑将Azure事件网格用于实时推送通知。