Azure Function高效触发器选型：每5分钟轮询Blob容器方案咨询

一、触发器选型：Timer Trigger仍是批量定时处理的最优选择 #

Blob Storage Trigger和Event Grid Trigger确实是实时触发单Blob处理，不符合你每5分钟批量处理的需求。目前Azure Functions生态里没有专门的「定时批量Blob触发器」，所以Timer Trigger依然是最适配你需求的方案，核心优化点在于后续的Event Hub发送逻辑。

二、优化发送效率：批量发送替代单Blob POST请求 #

你当前的脚本每个Blob单独发起POST请求，会产生大量HTTP开销，可通过以下两种方式实现批量发送，大幅提升效率：

1. 使用Azure Event Hub PowerShell模块批量发送 #

借助Az.EventHub模块的批量发送能力，自动管理批次大小，减少请求次数：

# 首次运行需安装模块
Install-Module -Name Az.EventHub -Force -Scope CurrentUser

# 初始化Event Hub客户端
$eventHub = Get-AzEventHub -ResourceGroupName $resourceGroupName -NamespaceName $EventHubsNamespace -Name $EventHubsName
$eventBatch = New-AzEventHubEventBatch -EventHub $eventHub

foreach($blob in $blobs) {
    Write-Host "Processing blob: $($blob.Name)"
    # 直接读取Blob内容，无需下载到本地
    $blobContent = $blob.ICloudBlob.DownloadText()

    # 尝试将事件加入批次，批次满则发送
    if (-not $eventBatch.TryAdd([Azure.Messaging.EventHubs.EventData]::CreateFromString($blobContent))) {
        Send-AzEventHubEventBatch -EventHub $eventHub -Batch $eventBatch
        $eventBatch = New-AzEventHubEventBatch -EventHub $eventHub
        $eventBatch.TryAdd([Azure.Messaging.EventHubs.EventData]::CreateFromString($blobContent)) | Out-Null
    }

    # 删除已处理Blob
    Remove-AzStorageBlob -Container $containerContext.Name -Blob $blob.Name -Context $storageContext -Force
}

# 发送剩余未填满的批次
if ($eventBatch.Count -gt 0) {
    Send-AzEventHubEventBatch -EventHub $eventHub -Batch $eventBatch
}

2. 使用Event Hub REST API批量发送 #

通过REST API的批量接口，将多个Blob内容打包成一个请求发送（需确保总内容不超过256KB限制）：

# 收集所有Blob内容
$eventList = @()
foreach($blob in $blobs) {
    Write-Host "Processing blob: $($blob.Name)"
    $eventList += $blob.ICloudBlob.DownloadText()
    Remove-AzStorageBlob -Container $containerContext.Name -Blob $blob.Name -Context $storageContext -Force
}

# 构建批量请求体（每个事件按换行分隔）
$batchBody = $eventList -join "`n"

# 复用你已有的SASToken生成逻辑（此处省略重复代码）
# ...

# 调整Content-Type为批量格式
$Headers = @{
    "Authorization"=$SASToken;
    "Content-Type"="application/vnd.microsoft.servicebus.json";
}

# 单次请求发送所有事件
Invoke-RestMethod -Uri $RestAPI -Method "POST" -Headers $Headers -Body $batchBody

三、额外优化点 #

• 取消本地Blob下载：直接通过$blob.ICloudBlob.DownloadText()读取内容，避免本地IO开销。
• 添加错误重试机制：给发送和删除逻辑加try-catch块，单个Blob处理失败时跳过或标记，避免中断整个批量任务。
• 简化权限管理：给函数托管身份分配Storage Blob Data Reader/Delete和Event Hub Data Sender角色，无需从Key Vault读取密钥，更安全高效。

内容的提问来源于stack exchange，提问作者Ross