Как мне прочитать данные журнала 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, которое, я полагаю, получит из журнала событий концентратора.
- В приложении "Логика" я создаю один текстовый файл и хочу получить имя этого вновь созданного файла из журналов концентраторов событий.
Есть идеи по поводу двух вопросов?
Я пробовал этот пост
Но в секунду создается несколько файлов, и какой именно файл содержит то, что мне нужно, как угадать?
код работает хорошо -
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();
}