Log BlobNotFound exception

youscan · Jan 10, 2024 · bb06d85 · bb06d85
1 parent a656abd
commit bb06d85
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/AzureBatchQueue/MessageQueue.cs b/AzureBatchQueue/MessageQueue.cs
@@ -1,4 +1,5 @@
 using System.Text.Json.Serialization;
+using Azure;
 using Azure.Storage.Blobs;
 using Azure.Storage.Blobs.Specialized;
 using Azure.Storage.Queues;
@@ -187,8 +188,16 @@ async Task<QueueMessage<T>> ToQueueMessage(QueueMessage m, CancellationToken ct)
         var payload = m.Body.ToMemory();
         if (IsBlobRef(m.Body, out var blobRef))
         {
-            var blobData = await container.GetBlobClient(blobRef!.BlobName).DownloadContentAsync(ct);
-            payload = blobData.Value.Content.ToMemory();
+            try
+            {
+                var blobData = await container.GetBlobClient(blobRef!.BlobName).DownloadContentAsync(ct);
+                payload = blobData.Value.Content.ToMemory();
+            }
+            catch (RequestFailedException ex) when (ex.Status == 404)
+            {
+                logger.LogError(ex, "Blob with name {blobRef!.BlobName} is not found for {messageId}", blobRef.BlobName, m.MessageId);
+                throw;
+            }
         }
 
         var item = serializer.Deserialize(payload);