我们有 Azure 存储容器，其中动态创建了子文件夹，我们希望监视此容器/子文件夹下 Blob 的创建，并每天触发一次电子邮件，并将当天添加的所有 Blob 作为电子邮件中的附件。
我们尝试的是创建一个带有事件网格触发器(当资源事件发生时)的逻辑应用程序，如下所示。
我们想知道是否有办法收集容器下一天内添加的所有 Blob，并获取所有这些 Blob 的内容并将其添加为附件，并每天在预定时间触发一封电子邮件。
任何建议
- 如何获取容器、子文件夹下的所有 blob 并将创建的 blob 元数据存储为数组？
- 然后如何附加在一封电子邮件中创建的所有 Blob？
- 如何在“资源事件发生时”触发器后获取 blob 名称？
最佳答案
根据上述要求，我们创建了一个逻辑应用程序，使用计时器来列出并获取在特定日期创建的所有 Blob 的内容，并将发送包含 Blob 内容作为附件的电子邮件。使用以下工作流程代码，您可以根据您的业务需求进行更改。
{
"definition": {
"$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
"actions": {
"Attach": {
"inputs": {
"variables": [
{
"name": "Arraytoattach",
"type": "array"
}
]
},
"runAfter": {
"Lists_blobs_(V2)": [
"Succeeded"
]
},
"type": "InitializeVariable"
},
"Blob_Name": {
"inputs": {
"variables": [
{
"name": "Count",
"type": "integer",
"value": "@length(variables('Arraytoattach'))"
}
]
},
"runAfter": {
"For_each": [
"Succeeded"
]
},
"type": "InitializeVariable"
},
"For_each": {
"actions": {
"Compose_2": {
"inputs": "@items('For_each')?['LastModified']",
"runAfter": {},
"type": "Compose"
},
"Compose_3": {
"inputs": "@formatDateTime(outputs('Compose_2'),'yyyy-MM-dd')",
"runAfter": {
"Compose_2": [
"Succeeded"
]
},
"type": "Compose"
},
"Condition": {
"actions": {
"Append_to_array_variable": {
"inputs": {
"name": "Arraytoattach",
"value": {
"ContentBytes": "@body('Get_blob_content_(V2)_2')?['$content']",
"Name": "@items('For_each')?['Name']"
}
},
"runAfter": {
"Get_blob_content_(V2)_2": [
"Succeeded"
]
},
"type": "AppendToArrayVariable"
},
"Get_blob_content_(V2)_2": {
"inputs": {
"host": {
"connection": {
"name": "@parameters('$connections')['azureblob']['connectionId']"
}
},
"method": "get",
"path": "/v2/datasets/@{encodeURIComponent(encodeURIComponent('stacklogictest'))}/files/@{encodeURIComponent(encodeURIComponent(items('For_each')?['Path']))}/content",
"queries": {
"inferContentType": true
}
},
"runAfter": {},
"type": "ApiConnection"
}
},
"expression": {
"and": [
{
"equals": [
"@outputs('Compose_3')",
"@formatDateTime(utcNow(),'yyyy-MM-dd')"
]
}
]
},
"runAfter": {
"Compose_3": [
"Succeeded"
]
},
"type": "If"
}
},
"foreach": "@body('Lists_blobs_(V2)')?['value']",
"runAfter": {
"Attach": [
"Succeeded"
]
},
"type": "Foreach"
},
"Lists_blobs_(V2)": {
"inputs": {
"host": {
"connection": {
"name": "@parameters('$connections')['azureblob']['connectionId']"
}
},
"method": "get",
"path": "/v2/datasets/@{encodeURIComponent(encodeURIComponent('stacklogictest'))}/foldersV2/@{encodeURIComponent(encodeURIComponent('JTJmdGVzdDEyMw=='))}",
"queries": {
"nextPageMarker": "",
"useFlatListing": false
}
},
"metadata": {
"JTJmdGVzdDEyMw==": "/test123"
},
"runAfter": {},
"type": "ApiConnection"
},
"Send_an_email_(V2)": {
"inputs": {
"body": {
"Attachments": "@variables('Arraytoattach')",
"Body": "<p>Total Number of blob created today : @{variables('Count')}</p>",
"Subject": "Blob created Today",
"To": "<**ReciepientMailAddress**>"
},
"host": {
"connection": {
"name": "@parameters('$connections')['office365']['connectionId']"
}
},
"method": "post",
"path": "/v2/Mail"
},
"runAfter": {
"Blob_Name": [
"Succeeded"
]
},
"type": "ApiConnection"
}
},
"contentVersion": "1.0.0.0",
"outputs": {},
"parameters": {
"$connections": {
"defaultValue": {},
"type": "Object"
}
},
"triggers": {
"Recurrence": {
"recurrence": {
"frequency": "Day",
"interval": 1,
"startTime": "2021-07-15T04:00:00Z"
},
"type": "Recurrence"
}
}
},
"parameters": {
"$connections": {
"value": {
"azureblob": {
"connectionId": "/subscriptions/<subscriptionId>/resourceGroups/<resourceGroups>/providers/Microsoft.Web/connections/azureblob",
"connectionName": "azureblob",
"id": "/subscriptions/<subscriptionId>/providers/Microsoft.Web/locations/southindia/managedApis/azureblob"
},
"office365": {
"connectionId": "/subscriptions/<subscriptionId>/resourceGroups/<resourceGroups>/providers/Microsoft.Web/connections/office365",
"connectionName": "office365",
"id": "/subscriptions/<subscriptionId>/providers/Microsoft.Web/locations/southindia/managedApis/office365"
}
}
}
}
}
- how to get all the blobs under a container, sub-folder and store the blobs metadata created as an array?
答:使用事件网格，您可以将特定容器下的所有 Blob 添加到单个数组，因为添加新 Blob 时事件网格会触发逻辑应用。
- And then how to attach all the blobs created in a single email?
答:由于 Outlook 限制，我们无法发送或附加超过 25 MB 的数据。
3.How to get the blob name after, "When a resource event occurs" trigger?
Ans:如下图所示，初始化一个字符串变量并将其添加到事件网格事件的下一个，并添加以下表达式以从事件网格输出中获取 blob 名称 首先(分割(最后(分割(字符串(triggerBody())，'/blobs/'))，'“，”事件'))
如果 blob 的内容类型是文本，则上述逻辑应用将失败，您需要根据要求进行相应的更改。
这是上述逻辑应用的示例输出
关于azure - 如何监视 Azure 存储容器/子文件夹中 Blob 的创建并触发逻辑应用发送电子邮件，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/68207551/