如何在本地Python Azure Functions中获取Blob路径读取netCDF文件

在Blob触发的Azure Functions中，func.InputStream对象并不提供本地文件路径——因为Blob存储在Azure Storage（本地运行时使用Azurite模拟器）中，并非本地磁盘文件。你可以通过以下两种方式处理netCDF文件：

方案一：写入临时文件后读取 #

将Blob内容写入本地临时文件，再用netCDF4.Dataset读取该文件，适合处理大文件：

import logging
import azure.functions as func
from netCDF4 import Dataset
import tempfile
import os

def main(myblob: func.InputStream):
    logging.info(f"Python blob trigger function processed blob \n"
                 f"Name: {myblob.name}\n"
                 f"Blob Size: {myblob.length} bytes")

    # 创建带.nc后缀的临时文件
    with tempfile.NamedTemporaryFile(suffix='.nc', delete=False) as temp_file:
        temp_file.write(myblob.read())
        temp_file_path = temp_file.name

    try:
        # 读取netCDF文件
        nc = Dataset(temp_file_path, mode='r')
        # 在这里添加业务处理逻辑，例如读取变量
        logging.info(f"读取到netCDF变量：{list(nc.variables.keys())}")
        nc.close()
    finally:
        # 清理临时文件，避免磁盘占用
        os.unlink(temp_file_path)

方案二：直接读取内存中的Blob内容 #

如果你的netCDF4版本支持，可以将Blob内容加载到内存中直接读取，适合小文件场景：

import logging
import azure.functions as func
from netCDF4 import Dataset

def main(myblob: func.InputStream):
    logging.info(f"Python blob trigger function processed blob \n"
                 f"Name: {myblob.name}\n"
                 f"Blob Size: {myblob.length} bytes")

    # 将Blob内容读取为字节数据，通过memory参数传入Dataset
    blob_bytes = myblob.read()
    nc = Dataset('in_memory_nc', mode='r', memory=blob_bytes)
    # 业务处理逻辑
    logging.info(f"读取到netCDF变量：{list(nc.variables.keys())}")
    nc.close()

注意事项 #

• 确保已安装依赖包：pip install netCDF4 azure-functions
• 本地运行时需在local.settings.json的Values中配置AzureWebJobsStorage连接字符串（指向Azurite）
• 大文件优先选择临时文件方案，避免内存占用过高

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