Монитор хранилища функциональных BLOB-объектов Azure

Первоначально у меня тоже возникла такая же проблема. В этом случае при добавлении типа событий BLOB-объекта в подписку на сетку событий триггер BLOB-объекта недоступен.

Для выполнения того же требования я создал функцию триггера сетки событий с изолированным стеком времени выполнения .NET 8.0.

Код функции:

using System;
using Azure.Messaging.EventGrid;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace Company.Function
{
    public class EventGridTrigger1
    {
        private readonly ILogger<EventGridTrigger1> _logger;

        public EventGridTrigger1(ILogger<EventGridTrigger1> logger)
        {
            _logger = logger;
        }

        [Function(nameof(EventGridTrigger1))]
        public void Run([EventGridTrigger] EventGridEvent eventGridEvent)
        {
            _logger.LogInformation("Event type: {type}, Event subject: {subject}", eventGridEvent.EventType, eventGridEvent.Subject);

            // Optional: Deserialize event data if needed
            var data = eventGridEvent.Data.ToString();
            _logger.LogInformation($"Event Data: {data}");
        }
    }
}

Я успешно развернул эту функцию на портале Azure.

• Я настроил конечную точку функции в подписке на сетку событий в storage events.

Когда я загрузил или удалил капли в функции контейнера, они успешно сработали. проверьте ниже:

Вывод сетки событий:

Выход функции:

Просто для тех, кому нужно полное решение, можно также читать капли. Это не использование изолированных сред выполнения.

// Default URL for triggering event grid function in the local environment.
// http://localhost:7071/runtime/webhooks/EventGrid?functionName = {functionname}
using System;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.EventGrid;
using Microsoft.Extensions.Logging;
using Azure.Messaging.EventGrid;
using Azure.Storage.Blobs;
using System.Threading.Tasks;
using System.IO;
using System.Text.Json;
using Newtonsoft.Json.Linq;
using Azure.Identity;
using Azure.Storage.Blobs.Models;

namespace XXX
{
    public static class BlobEventTrigger
    {
        [FunctionName("BlobEventTrigger")]
        public static async Task RunAsync([EventGridTrigger]EventGridEvent eventGridEvent, ILogger log)
    {
            log.LogInformation($"Event Grid trigger function processed an event: {eventGridEvent.EventType}");

            if (eventGridEvent.EventType == "Microsoft.Storage.BlobCreated")
            {
            StorageBlobCreatedEventData createdEvent;

            if (eventGridEvent.Data is BinaryData binaryData)
            {
                string jsonData = binaryData.ToString();
                JObject jObject = JObject.Parse(jsonData);
                createdEvent = jObject.ToObject<StorageBlobCreatedEventData>();
            }
            else
            {
                throw new InvalidOperationException("Unexpected event data type");
            }
    
            log.LogInformation($"Blob: {createdEvent.Url}");
            log.LogInformation($"Api operation: {createdEvent.Api}");
 

            if (string.IsNullOrEmpty(createdEvent.Url))
            {
                log.LogInformation($"Blob content: {createdEvent.Url}");
                log.LogError("Event data or Blob URL is null or empty.");
                return;
            }

             var credential = new DefaultAzureCredential(new DefaultAzureCredentialOptions
            {
                ManagedIdentityClientId = "XXXXXXXX"
            });

            // Create a BlobClient from the blob URL
            BlobClient blobClient = new BlobClient(new Uri(createdEvent.Url),credential);

            try
            {
                // Download the blob content
                var response = await blobClient.DownloadAsync();

                // Check if the blob exists and log its properties
                BlobProperties properties = await blobClient.GetPropertiesAsync();
                log.LogInformation($"Blob properties: {properties.BlobType}, {properties.ContentType}");


                // Download the blob content
                BlobDownloadInfo download = await blobClient.DownloadAsync();
                using (StreamReader reader = new StreamReader(download.Content, true))
                {
                    string content = await reader.ReadToEndAsync();
                    log.LogInformation($"Blob content: {content}");
                }
            }
            catch (Exception ex)
            {
                log.LogError($"Error reading blob: {ex.Message}");
            }
        }
    }
}

    public class StorageBlobCreatedEventData
    {
        public string Api { get; set; }
        public string ClientRequestId { get; set; }
        public string RequestId { get; set; }
        public string ETag { get; set; }
        public string ContentType { get; set; }
        public int ContentLength { get; set; }
        public string BlobType { get; set; }
        public string Url { get; set; }
        public string Sequencer { get; set; }
        public StorageDiagnostics StorageDiagnostics { get; set; }
    }

    public class StorageDiagnostics
    {
        public string BatchId { get; set; }
    }
}