如何通过Azure Function将Azure存储NFS文件共享数据复制到Blob容器

方案1：Azure Function挂载NFS共享 + Storage SDK直接上传 #

这是最直接的实现方式，通过Azure Function的持久存储挂载功能将NFS文件共享映射到Function的本地文件系统，再用Azure Storage Blob SDK读取文件并上传至目标容器。

操作步骤： #

• 在Azure Function的配置页面，添加持久存储，选择已有的NFS文件共享，设置挂载路径（比如/mnt/nfs）。
• 为Function配置目标Blob容器的连接字符串（通过应用设置添加AZURE_STORAGE_CONNECTION_STRING）。
• 编写Function代码，遍历挂载目录的文件并上传。

Python代码示例（定时触发或HTTP触发）： #

import os
from azure.storage.blob import BlobServiceClient
from azure.core.exceptions import ResourceExistsError

def main(mytimer=None):
    # 初始化Blob服务客户端
    blob_service_client = BlobServiceClient.from_connection_string(
        os.environ["AZURE_STORAGE_CONNECTION_STRING"]
    )
    container_client = blob_service_client.get_container_client("your-target-container")

    # NFS共享挂载路径
    nfs_mount_dir = "/mnt/nfs"

    # 遍历目录下所有文件
    for root, _, files in os.walk(nfs_mount_dir):
        for filename in files:
            local_file_path = os.path.join(root, filename)
            # 保持原目录结构作为Blob路径
            blob_path = os.path.relpath(local_file_path, nfs_mount_dir)
            
            try:
                with open(local_file_path, "rb") as file_data:
                    container_client.upload_blob(
                        name=blob_path,
                        data=file_data,
                        overwrite=True
                    )
                print(f"Uploaded {blob_path} successfully")
            except ResourceExistsError:
                print(f"Blob {blob_path} already exists, skipped")
            except Exception as e:
                print(f"Failed to upload {blob_path}: {str(e)}")
    
    return "Copy task completed"

方案2：自定义容器版Azure Function预挂载NFS #

如果需要更灵活的挂载配置（比如自定义挂载参数），可以用自定义容器部署Function，在容器启动时完成NFS挂载。

关键配置： #

• 在Dockerfile中安装NFS客户端工具，并添加启动脚本挂载NFS：

FROM mcr.microsoft.com/azure-functions/python:4-python3.11

RUN apt-get update && apt-get install -y nfs-common

# 复制Function代码
COPY . /home/site/wwwroot

# 设置启动命令，先挂载NFS再启动Function
CMD ["sh", "-c", "mount -t nfs <your-nfs-share-fqdn>:/<your-share-name> /mnt/nfs && func start"]

• 后续代码逻辑同方案1，直接访问/mnt/nfs目录即可。

方案3：Event Grid触发增量复制 #

如果只需要同步新增/修改的文件，可通过Azure Event Grid订阅NFS文件共享的文件事件，触发Function实时处理。

操作步骤： #

• 在Azure存储账户中为NFS文件共享启用Event Grid事件，订阅File Created和File Updated事件。
• 将事件触发目标设置为你的Azure Function。
• 在Function代码中解析Event Grid传递的文件路径，读取NFS共享中的对应文件并上传至Blob。

注意事项： #

• 批量复制大量文件时，建议使用Premium或专用计划的Azure Function，避免消费计划的10分钟执行时间限制。
• 确保Function所在的虚拟网络（如果有）能访问NFS文件共享的IP范围，且Function拥有存储账户的Storage Blob Data Contributor权限和NFS共享的访问权限。
• 大文件（>100MB）可使用SDK的分块上传功能，避免内存溢出。

内容的提问来源于stack exchange，提问作者hb.Sara