如何用PowerShell编写Azure Function读取Event Hub数据并推送至本地REST API

你已经完成混合连接配置的前提下，直接在PowerShell代码中调用Invoke-RestMethod向本地REST API地址发POST请求即可，不需要额外的网络适配配置。以下是各文件的调整参考：

1. run.ps1 核心逻辑修改 #

param($eventHubMessages, $TriggerMetadata)

# 敏感配置全部从应用环境变量读取，禁止硬编码
$localApiAddr = $env:LOCAL_REST_API_ENDPOINT
$apiAuthToken = $env:LOCAL_API_AUTH_TOKEN # 若本地接口无鉴权可删除该行

Write-Information "收到Event Hub消息批次，总消息数：$($eventHubMessages.Count)"

foreach ($msg in $eventHubMessages) {
    try {
        # 构造请求头，根据本地接口实际要求调整
        $reqHeaders = @{
            "Content-Type" = "application/json"
            "Authorization" = "Bearer $apiAuthToken" # 无鉴权可删除该行
        }
        # 消息转JSON作为请求体，若上游传入的已是标准JSON可直接使用$msg
        $reqBody = $msg | ConvertTo-Json -Depth 10

        # 发起POST请求到本地接口
        $apiRes = Invoke-RestMethod -Uri $localApiAddr -Method Post -Headers $reqHeaders -Body $reqBody -TimeoutSec 20
        Write-Information "消息处理成功，接口返回：$($apiRes | ConvertTo-Json -Depth 5)"
    }
    catch {
        Write-Error "消息处理失败，错误详情：$_ ，对应消息内容：$msg"
        # 可在此处加重试、写入死信队列等异常兜底逻辑
    }
}

2. host.json 可选优化配置 #

你原有配置可用，若需要优化批量处理性能、调整超时阈值可参考以下配置：

{
  "version": "2.0",
  "managedDependency": {
    "Enabled": true
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[3.*, 4.0.0)"
  },
  "extensions": {
    "eventHubs": {
      "batchCheckpointFrequency": 1,
      "eventProcessorOptions": {
        "maxBatchSize": 32,
        "prefetchCount": 64
      }
    }
  },
  "functionTimeout": "00:05:00"
}

3. function.json 配置说明 #

你现有配置无需修改，只需确认在Function App的应用配置中已正确添加名为eventhub-reciever-policy的Event Hub连接字符串，以及前面代码用到的LOCAL_REST_API_ENDPOINT、LOCAL_API_AUTH_TOKEN两个配置项即可。

• 始终启用托管依赖：你已经开启该配置，平台会自动拉取匹配版本的依赖模块，无需手动上传模块包
• 区分日志级别：避免全用Write-Host输出日志，根据场景使用Write-Information、Write-Error、Write-Warning区分日志类型，禁止在日志中输出密钥、用户隐私等敏感信息
• 做好幂等性处理：Event Hub为至少一次投递机制，本地REST API需要做好重复消息的识别逻辑，避免重复执行业务操作
• 异常兜底机制：调用外部接口失败时增加退避重试逻辑，瞬时故障自动重试，达到最大重试次数后将异常消息写入死信队列，避免消息丢失
• 禁止硬编码配置：所有连接字符串、接口地址、鉴权密钥等配置全部放到Function App的应用配置中，代码通过环境变量读取
• 合理设置批量大小：根据本地接口的处理能力调整Event Hub的拉取批次大小，避免批次过大导致处理超时

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