Azure Functions v4 URL重写实现存储账户Blob访问问题

问题分析 #

你当前的核心问题有两个：

1. 路由配置仅匹配根路径/，导致访问/index.html或其他Blob路径时触发404
2. 部署到Azure后，本地正常的Blob认证逻辑在函数环境中失效

该需求完全可行，以下是分步解决方案：

一、修正路由配置，捕获所有路径 #

修改function.json中的route字段为{*path}，让HTTP触发器匹配根路径下的所有请求（而非仅/）：

{
    "bindings": [
      {
        "authLevel": "anonymous",
        "route": "{*path}",
        "type": "httpTrigger",
        "direction": "in",
        "name": "req",
        "methods": [
          "get"
        ]
      },
      {
        "type": "http",
        "direction": "out",
        "name": "res"
      }
    ]
  }

host.json的routePrefix为空配置保持不变，确保URL中没有/api前缀。

二、调整Go代码，适配函数环境与路径处理 #

替换原有代码，实现以下逻辑：

• 用Azure系统托管身份完成存储账户认证（避免本地凭据与部署环境不一致）
• 解析请求路径，动态获取对应Blob
• 默认返回index.html作为引导页

package main

import (
	"context"
	"fmt"
	"io"
	"log"
	"net/http"
	"os"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/storage/azblob"
)

var blobClient *azblob.Client
var containerName = "your-container-name" // 替换为你的存储容器名

func init() {
	// 初始化Blob客户端，使用系统托管身份
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("初始化身份认证失败: %v", err)
	}

	accountName := "your-storage-account-name" // 替换为你的存储账户名
	client, err := azblob.NewClient(fmt.Sprintf("https://%s.blob.core.windows.net", accountName), cred, nil)
	if err != nil {
		log.Fatalf("初始化Blob客户端失败: %v", err)
	}
	blobClient = client
}

func HttpTrigger(w http.ResponseWriter, r *http.Request) {
	// 解析请求路径，去掉开头的/
	path := r.URL.Path[1:]
	if path == "" {
		// 根路径默认返回index.html
		path = "index.html"
	}

	// 下载Blob流
	getResp, err := blobClient.DownloadStream(context.Background(), containerName, path, nil)
	if err != nil {
		w.WriteHeader(http.StatusNotFound)
		fmt.Fprintf(w, "Blob不存在: %v", err)
		return
	}
	defer getResp.Body.Close()

	// 设置响应Content-Type（从Blob属性获取）
	props, err := blobClient.GetBlobProperties(context.Background(), containerName, path, nil)
	if err == nil {
		w.Header().Set("Content-Type", *props.ContentType)
	}

	// 将Blob内容写入响应
	w.WriteHeader(http.StatusOK)
	_, _ = io.Copy(w, getResp.Body)
}

func main() {
	http.HandleFunc("/", HttpTrigger)
	port := os.Getenv("PORT")
	if port == "" {
		port = "8080"
	}
	log.Printf("服务启动，监听端口: %s", port)
	log.Fatal(http.ListenAndServe(":"+port, nil))
}

三、配置函数应用的存储权限 #

1. 进入Azure门户的函数应用，左侧菜单选择身份，启用系统分配的托管身份
2. 进入目标存储账户的访问控制(IAM)，添加角色分配：
   • 角色选择「存储Blob数据读取者」
   • 成员类型选择「托管身份」，并选中你的函数应用
3. 保存配置，等待1-2分钟让权限生效

四、验证部署 #

部署修改后的代码与配置后：

• 访问https://<你的函数应用名>.azurewebsites.net/会返回index.html
• 访问https://<你的函数应用名>.azurewebsites.net/<Blob文件名>会直接返回对应Blob内容

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