Azure 队列 - 可见性超时 - 触发的 WebJob
Azure Queue - Visibility Time-Out - Triggered WebJob
我想更改时间跨度，在消息到达队列时触发 webjob 的情况下，Q 消息是不可见的。
我在开发阶段调试时需要这个。有时，旧的 Q-msg 会由于错误而重新出现，但我已经清理了该消息所指的 blob-storage-item。因此 WebJob 崩溃，因为它试图获取不存在的 blob 对象。
如果我可以设置 Q 消息在 1 分钟后再次可见，那将会很有帮助。
public 部分 class 函数
{
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
)
{
在最新的 v1.1.0 版 SDK 中，我们添加了让您添加自定义 QueueProcessor 以控制消息处理的各个方面的功能。您可以查看您要执行的操作的示例 here in our tests。
在该示例中，对于失败的消息，您可以根据错误详细信息将可见性显式设置为您自己的值。您可以通过创建自己的工厂并将其设置为 JobHostConfiguration.Queues.QueueProcessorFactory.
来注册自定义 QueueProcessors
我想更改时间跨度，在消息到达队列时触发 webjob 的情况下，Q 消息是不可见的。
我在开发阶段调试时需要这个。有时，旧的 Q-msg 会由于错误而重新出现，但我已经清理了该消息所指的 blob-storage-item。因此 WebJob 崩溃，因为它试图获取不存在的 blob 对象。
如果我可以设置 Q 消息在 1 分钟后再次可见，那将会很有帮助。
public 部分 class 函数 { 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 ) {
在最新的 v1.1.0 版 SDK 中，我们添加了让您添加自定义 QueueProcessor 以控制消息处理的各个方面的功能。您可以查看您要执行的操作的示例 here in our tests。
在该示例中，对于失败的消息，您可以根据错误详细信息将可见性显式设置为您自己的值。您可以通过创建自己的工厂并将其设置为 JobHostConfiguration.Queues.QueueProcessorFactory.
来注册自定义 QueueProcessors