Как мне прочитать данные журнала Event Hub, которые записываются в blob с помощью C#

Я имею simple logic app который creates a text file,

я бы хотел test whether the logic app created file is present in file storage,

А также хочу проверить значение correlation id of logic app

Я создал Event Hub а также In Logic app configure Diagnostic Settings to Stream to an event hub,

Сейчас Inside Event hub I have configure Capture option to Azure Storage which will create a blob file for events logs

Интересно, как я могу проверить 2 вещи из BLOB-объектов событий, используя код C#?

Я хочу проверить следующее -

1. При запуске приложения логики я хочу проверить свойство correlation_ID, которое, я полагаю, получит из журнала событий концентратора.

  1. В приложении "Логика" я создаю один текстовый файл и хочу получить имя этого вновь созданного файла из журналов концентраторов событий.

Есть идеи по поводу двух вопросов?

Я пробовал этот пост

Но в секунду создается несколько файлов, и какой именно файл содержит то, что мне нужно, как угадать?

код работает хорошо -

var storageAccount = CloudStorageAccount.Parse(connectionString);
 var blobClient = storageAccount.CreateCloudBlobClient();
 var container = blobClient.GetContainerReference(containerName);
 var blob = container.GetBlockBlobReference(blobName);
 using (var stream = blob.OpenRead())
 using (var reader = AvroContainer.CreateGenericReader(stream))
     while (reader.MoveNext())
         foreach (dynamic result in reader.Current.Objects)
         {
             var record = new AvroEventData(result);
             record.Dump();
         }

0 ответов

Другие вопросы по тегам