如何在Python开发的Azure Function App中访问JSON Blob内容

前置权限配置 #

• 优先使用托管标识鉴权，避免硬编码密钥：进入Function App侧边栏「身份」选项，开启系统分配托管标识并保存；随后跳转至存储账户的「访问控制(IAM)」页面，为刚才启用的Function托管标识分配存储Blob数据读取者角色，作用域覆盖存储JSON文件的目标容器即可。
• 若使用连接字符串鉴权，复制存储账户的访问密钥或连接字符串，存入Function App「配置-应用设置」中，自定义键名（例如BlobStorageConn），后续代码/绑定直接读取该配置，禁止硬编码在代码文件中。

实现方式1：Blob输入绑定（代码量最少，推荐固定路径场景） #

输入绑定是Azure Function原生提供的能力，无需手动编写存储连接逻辑，配置完成后函数运行时会自动加载目标Blob内容到入参：

• 若使用声明式配置（非C#特性/注解模式），在function.json中添加Blob输入绑定片段：

{
  "type": "blob",
  "direction": "in",
  "name": "targetJsonBlob",
  "path": "你的容器名/{fileName}.json",
  "connection": "BlobStorageConn"
}

其中路径中的{fileName}支持从HTTP请求的Query参数、路由参数中自动取值，无需手动解析请求。

• 配置完成后，直接在函数入参中读取targetJsonBlob对应的内容即可，运行时会自动将Blob内容转为流/字符串格式，直接反序列化为JSON对象即可使用，例如Python环境下直接执行json.loads(targetJsonBlob)即可拿到结构化数据。
• 若使用C#/Java等支持特性注解的语言，直接在函数方法参数上添加对应Blob输入注解，传入路径、连接配置名即可，无需手动编写function.json。

实现方式2：SDK手动读取（灵活度最高，推荐动态路径场景） #

如果Blob路径需要在运行时动态拼接、逻辑判断，直接通过官方Blob SDK读取即可：

• 先为项目安装对应语言的Blob依赖包：
  • .NET：安装Azure.Storage.Blobs、Azure.Identity
  • Python：安装azure-storage-blob、azure-identity
  • Node.js：安装@azure/storage-blob、@azure/identity
• 核心读取逻辑示例（Python版，其他语言逻辑完全一致）：

import azure.functions as func
import json
import os
from azure.storage.blob import BlobClient
from azure.identity import DefaultAzureCredential

def main(req: func.HttpRequest) -> func.HttpResponse:
    # 从HTTP请求中获取目标Blob参数，可根据业务逻辑自行调整参数来源
    container = req.params.get("container")
    blob_name = req.params.get("blobName")
    if not container or not blob_name:
        return func.HttpResponse("Missing required container/blobName parameter", status_code=400)

    # 初始化Blob客户端，托管标识鉴权无需传入密钥
    storage_account = os.environ["StorageAccountName"]
    blob_client = BlobClient(
        account_url=f"https://{storage_account}.blob.core.windows.net",
        container_name=container,
        blob_name=blob_name,
        credential=DefaultAzureCredential()
    )

    # 下载并解析JSON
    raw_content = blob_client.download_blob().readall()
    try:
        json_data = json.loads(raw_content.decode("utf-8-sig"))
    except json.JSONDecodeError as e:
        return func.HttpResponse(f"Invalid JSON content in blob: {str(e)}", status_code=500)

    # 此处编写自定义数据转换逻辑
    # transformed_result = your_transform_logic(json_data)

    return func.HttpResponse(
        json.dumps({"status": "success", "data": json_data}),
        mimetype="application/json"
    )

若使用连接字符串鉴权，初始化BlobClient时直接传入从应用设置读取的连接字符串即可，无需调用DefaultAzureCredential。

无法读取JSON内容的常见排查点 #

• 权限类错误（403）：检查托管标识角色分配是否生效（角色赋值有1-2分钟延迟）、连接字符串是否匹配当前存储账户、是否配置了VNet或防火墙拦截Function的出站请求。
• 找不到Blob错误（404）：检查Blob路径是否正确，路径格式为容器名/文件全路径，不要遗漏容器名，注意Blob文件名大小写敏感，不要多写前置斜杠。
• 解析错误：读取内容后先打印原始字符串日志，检查Blob内的JSON是否合法、是否带UTF-8 BOM头、是否存在非JSON格式的冗余内容。
• 配置错误：本地调试时配置要写入local.settings.json的Values节点，线上部署时要检查配置是否同步到对应部署槽，不要把本地调试配置提交到代码仓库。

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