У меня есть фабрика данных, которая запускается на основе события большого двоичного объекта хранилища. В запущенном событии я вижу два свойства TriggerTime и EventPayload. Поскольку мне нужно прочитать информацию, связанную с Storage Blob, я пытаюсь обработать EventPayload в фабрике данных. Я хотел бы получить доступ к такому свойству как 'url' из тега данных.
Пример полезной нагрузки выглядит следующим образом:
{
"topic":"/subscriptions/7xxxxe5bbccccc85/resourceGroups/das00/providers/Microsoft.Storage/storageAccounts/datxxxxxx61",
"subject":"/blobServices/default/containers/raw/blobs/sample.parquet",
"eventType":"Microsoft.Storage.BlobCreated",
"id":"a1c320d7-501f-0047-362c-xxxxxxxxxxxx",
"data":{
"api":"FlushWithClose",
"requestId":"5010",
"eTag":"0x8D82743B5D86E72",
"contentType":"application/octet-stream",
"contentLength":203665463,
"contentOffset":0,
"blobType":"BlockBlob",
"url":"https://mystorage.dfs.core.windows.net/raw/sample.parquet",
"sequencer":"000000000000000000000000000066f10000000000000232",
"storageDiagnostics":{
"batchId":"89308627-6e28-xxxxx-96e2-xxxxxx"
}
},
"dataVersion":"3",
"metadataVersion":"1",
"eventTime":"2020-07-13T15:45:04.0076557Z"
}
Есть ли какие-то короткие руки для обработки EventPayload в фабрике данных ? Например, имя файла и путь к папке события можно получить с помощью @triggerBody () в фабрике данных. Требуется ли для этого специальный код, например Azure function?