【问题标题】:Azure Queue - Visibility Time-Out - Triggered WebJobAzure 队列 - 可见性超时 - 触发的 WebJob
【发布时间】:2016-02-29 17:32:24
【问题描述】:

我喜欢在消息到达队列时触发 webjob 的情况下更改 Q 消息不可见的时间跨度。

我在调试时在开发阶段需要这个。有时,由于错误,旧的 Q-msg 会重新出现,但我已经清理了消息所指的 blob-storage-item。因此 WebJob 崩溃是因为它试图获取不存在的 blob 对象。

如果我可以设置 Q 消息在 1 分钟后再次可见,那将很有帮助。

公共部分类函数 { 公共静态无效 ProcessBulkFileQ( [QueueTrigger(AppConst.Q_BULKFILES)] JobInfo JobInfo, [Blob(AppConst.CONTAINER_BULKFILES + "/{BlobName}", FileAccess.Read)] 流输入流, [Blob(AppConst.CONTAINER_BULKFILES + "/{BlobName}")] CloudBlockBlob BlobToDelete ) {

【问题讨论】:

    标签: azure azure-webjobs azure-storage-queues


    【解决方案1】:

    在 SDK 的最新 v1.1.0 版本中,我们为您添加了添加自定义 QueueProcessor 来控制消息处理的各个方面的功能。你可以看到一个你想要做什么的例子here in our tests

    在该示例中,对于失败的消息,您可以根据错误详细信息将可见性显式设置为您自己的值。您可以通过创建自己的工厂并将其设置在 JobHostConfiguration.Queues.QueueProcessorFactory 上来注册自定义队列处理器。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2017-09-14
      • 1970-01-01
      • 2016-05-11
      • 1970-01-01
      • 2021-10-19
      相关资源
      最近更新 更多