使用Go开发带Event Grid触发器的Azure Function遇500错误求助

核心问题分析 #

日志中的404 (Not Found)错误表明，Azure Functions Runtime在将Event Grid请求转发到你的Go自定义处理程序时，找不到匹配的路由。结合你的代码与配置，主要存在以下几个问题：

1. 路由路径不匹配
   对于非HTTP类触发器（如Event Grid Trigger），Azure Functions自定义处理程序的请求转发路径为/{functionName}（不带/api前缀），但你的Go代码注册的路由是/api/EventGridTrigger，导致请求无法匹配处理函数，最终返回500错误。

2. function.json配置冗余/错误

   • authLevel字段对Event Grid Trigger无效，该触发器的认证通过webhook的code参数完成，无需配置此选项。
   • name字段应对应Event Grid事件对象的参数标识，常规配置为eventGridEvent而非req。

3. 事件格式可能不符合要求
   Event Grid要求发送的事件必须是JSON数组格式，若你的eventgridtriggerschema.json是单个事件对象而非数组，会引发解析失败，间接导致错误。

解决步骤 #

1. 修改Go代码的路由路径

将注册的路由去掉/api前缀，匹配非HTTP触发器的转发规则：

func eventGridTriggerHandler(w http.ResponseWriter, r *http.Request) {
   log.Printf("Received message!")
   // 建议添加响应状态码，避免runtime认为处理失败
   w.WriteHeader(http.StatusOK)
}

func main() {
  listenAddr := ":8080"
  if val, ok := os.LookupEnv("FUNCTIONS_CUSTOMHANDLER_PORT"); ok {
    listenAddr = ":" + val
  }
  // 移除/api前缀，匹配Event Grid Trigger的转发路径
  http.HandleFunc("/EventGridTrigger", eventGridTriggerHandler)
  log.Printf("About to listen on %s. Go to http://127.0.0.1%s/", listenAddr, listenAddr)
  log.Fatal(http.ListenAndServe(listenAddr, nil))
}

2. 修正function.json配置

移除无效字段，调整参数标识：

{
  "bindings": [
    {
      "type": "eventGridTrigger",
      "direction": "in",
      "name": "eventGridEvent"
    }
  ]
}

3. 确保Event Grid事件为数组格式

检查eventgridtriggerschema.json，确保内容是事件数组（示例格式）：

[
  {
    "id": "1807",
    "eventType": "Microsoft.Storage.BlobCreated",
    "subject": "/blobServices/default/containers/testcontainer/blobs/testfile.txt",
    "eventTime": "2017-08-16T20:33:51.059Z",
    "data": {
      "api": "PutBlockList",
      "clientRequestId": "6d79dbfb-0e37-4fc4-981f-442c9ca65760",
      "requestId": "831e1650-001e-001b-66ab-eeb76e000000",
      "eTag": "0x8D4BCC2E4835CD0",
      "contentType": "text/plain",
      "contentLength": 524288,
      "blobType": "BlockBlob",
      "url": "https://teststorage.blob.core.windows.net/testcontainer/testfile.txt",
      "sequencer": "00000000000004420000000000028963",
      "storageDiagnostics": {
        "batchId": "b68529f3-68cd-4744-baa4-3c0498ec19f0"
      }
    },
    "dataVersion": "",
    "metadataVersion": "1",
    "topic": "/subscriptions/{subscription-id}/resourceGroups/{resource-group}/providers/Microsoft.Storage/storageAccounts/{storage-account}"
  }
]

4. 开启详细日志排查（可选）

若问题仍存在，可在host.json的logging.logLevel中添加自定义处理程序的日志跟踪，查看转发请求的详细信息：

"logLevel": {
    "default": "Information",
    "Host.Results": "Error",
    "Function": "Trace",
    "Host.Aggregator": "Trace",
    "Host.CustomHandlers": "Trace"
}

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