1

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

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

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

公共部分类函数 { public static void ProcessBulkFileQ( [QueueTrigger(AppConst.Q_BULKFILES)] JobInfo JobInfo, [Blob(AppConst.CONTAINER_BULKFILES + "/{BlobName}", FileAccess.Read)] 流 InputStream, [Blob(AppConst.CONTAINER_BULKFILES + "/{BlobName}")] CloudBlockBlob BlobToDelete ) {

4

1 回答 1

5

在 SDK 的最新 v1.1.0 版本中，我们为您添加了添加自定义QueueProcessor以控制消息处理的各个方面的功能。您可以在我们的测试中看到您希望在此处执行的操作的示例。

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

于 2015-11-26T17:02:21.843 回答