如何将从blob触发器收到的请求排队？

Question

我有一个功能应用程序，当blob被上传或更新时触发。但在我的要求中，我的容器可能一次接收数千个blob（客户将批量将blob上传到容器）。在这种情况下，正如我所知，函数app将为容器中的每个blob并行运行。但我需要在队列中处理它们。因此，我想在这里使用队列存储。每当上传blob时，让我通过blob触发功能应用程序将该blob名称作为队列消息添加到队列存储中，然后我将拥有一个队列触发功能应用，它将触发并处理队列中的blob。如果我的方法错误，请纠正我？此外，我需要知道是否有任何方法可以从函数应用程序添加队列消息。

Answer 1

你的方法是正确的。我在我的应用程序中也做了同样的事情当多个用户在blob上上传图像时，我在存储队列上添加了blobname和url。您可以创建Azure函数来处理来自队列的消息，但请确保您的Azure函数batchSize为1

Azure 函数存储队列触发器 defatult 批量大小为 16，它将并行处理 16 条消息。host.json

创建新实体并在队列中上传实体详细信息的示例API代码。

await this.adRepository.AddEntity(ad);           
        var adDto = this.mapper.Map<AzureSearchServiceDto>(ad);

        //Push data in Queue
        await this.storageService.PushMessageIntoQueue(AppConstraint.ImageVerificationQueue, adDto .ToJson());

验证图像和创建缩略图图像的功能

[FunctionName("ImageVerificationFunction")]
    public async Task Run([QueueTrigger("%ImageVerificationQueue%", Connection = "StorageConnection")]string message, ILogger log)
    {
        log.LogInformation($"ImageVerificationFunction processed: {message}");
        var azureSearchServiceDto = JsonConvert.DeserializeObject<AzureSearchServiceDto>(message);
        await this.imageVerificationService.Verify(azureSearchServiceDto);
    }

存储服务是我的自定义服务，用于在存储队列中发送消息

Answer 2

应在方案中使用Azure事件网格推拉事件模式，其中存储帐户将事件直接推送到存储队列订阅者处理程序。

此解决方案不需要任何编码。