.NET版AWS Lambda能否将文件传输至Windows指定共享文件夹？

这个需求完全可行，但需要满足网络连通性和权限配置两个核心前提，以下是具体实现步骤和注意事项：

一、核心前提 #

• Lambda必须部署在能访问Windows共享的网络环境中：比如和共享服务器同属一个VPC，或者通过VPC对等连接、VPN/专线打通网络，同时确保安全组允许Lambda出站访问SMB协议的445端口
• Windows共享需配置合适权限：要么允许Lambda执行角色对应的AWS身份（如果使用AD集成）访问，要么准备一个有共享读写权限的Windows账号

二、具体实现步骤 #

1. 配置Lambda基础环境 #

• 将Lambda函数部署到目标VPC的子网，关联安全组开放445端口出站规则
• 给Lambda执行角色添加权限：
  • S3只读权限（比如AmazonS3ReadOnlyAccess），用于读取S3文件
  • 若用Secrets Manager存储Windows账号密码，需添加secretsmanager:GetSecretValue权限

2. .NET Lambda核心代码实现 #

逻辑很简单：从S3下载文件到Lambda临时目录，再上传到Windows共享。这里提供完整的.NET 6+示例代码：

using Amazon.Lambda.Core;
using Amazon.S3;
using Amazon.S3.Model;
using System.IO;
using System.Net;

[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]

namespace S3ToWindowsShareSync
{
    public class Function
    {
        private readonly IAmazonS3 _s3Client;
        // 替换为你的Windows共享路径、账号（建议从Secrets Manager获取）
        private readonly string _sharePath = @"\\your-win-server\shared-folder";
        private readonly string _shareUser = "domain\\username";
        private readonly string _sharePwd = "your-password";

        public Function()
        {
            _s3Client = new AmazonS3Client();
        }

        public async Task HandleS3Event(S3Event s3Event, ILambdaContext context)
        {
            foreach (var record in s3Event.Records)
            {
                var bucket = record.S3.Bucket.Name;
                var fileKey = record.S3.Object.Key;
                var fileName = Path.GetFileName(fileKey);

                try
                {
                    // 1. 下载S3文件到Lambda临时目录
                    var tempFile = Path.Combine(Path.GetTempPath(), fileName);
                    using (var s3Response = await _s3Client.GetObjectAsync(bucket, fileKey))
                    {
                        await s3Response.WriteResponseStreamToFileAsync(tempFile, false);
                    }

                    // 2. 上传到Windows共享
                    var targetPath = Path.Combine(_sharePath, fileName);
                    using (var networkConn = new NetworkConnection(_sharePath, new NetworkCredential(_shareUser, _sharePwd)))
                    {
                        File.Copy(tempFile, targetPath, overwrite: true);
                        context.Logger.LogInformation($"文件 {fileName} 已同步到共享路径 {targetPath}");
                    }
                }
                catch (Exception ex)
                {
                    context.Logger.LogError($"处理文件 {fileKey} 失败：{ex.Message}");
                    throw;
                }
            }
        }
    }

    // 辅助类：处理Windows共享连接
    public class NetworkConnection : IDisposable
    {
        private readonly string _shareName;

        public NetworkConnection(string shareName, NetworkCredential credentials)
        {
            _shareName = shareName;
            var netResource = new NetResource
            {
                ResourceType = ResourceType.Disk,
                RemoteName = shareName,
                Scope = ResourceScope.GlobalNetwork,
                DisplayType = ResourceDisplaytype.Share
            };

            var result = WNetAddConnection2(netResource, credentials.Password, credentials.UserName, 0);
            if (result != 0)
            {
                throw new InvalidOperationException($"连接共享失败，错误码：{result}");
            }
        }

        public void Dispose()
        {
            WNetCancelConnection2(_shareName, 0, true);
        }

        [System.Runtime.InteropServices.DllImport("mpr.dll")]
        private static extern int WNetAddConnection2(NetResource netResource, string password, string username, int flags);

        [System.Runtime.InteropServices.DllImport("mpr.dll")]
        private static extern int WNetCancelConnection2(string name, int flags, bool force);
    }

    [System.Runtime.InteropServices.StructLayout(System.Runtime.InteropServices.LayoutKind.Sequential)]
    public class NetResource
    {
        public ResourceScope Scope;
        public ResourceType ResourceType;
        public ResourceDisplaytype DisplayType;
        public int Usage;
        public string LocalName;
        public string RemoteName;
        public string Comment;
        public string Provider;
    }

    public enum ResourceScope : int
    {
        GlobalNetwork = 2
    }

    public enum ResourceType : int
    {
        Disk = 1
    }

    public enum ResourceDisplaytype : int
    {
        Share = 3
    }
}

3. 关键注意事项 #

• Lambda临时存储限制：默认512MB，若文件超过这个大小，需在Lambda配置中调整临时存储（最大10GB）
• 凭证安全：绝对不要硬编码账号密码，用AWS Secrets Manager存储，在代码中通过SDK动态获取
• 权限验证：提前测试Windows共享的访问权限，确保指定账号能读写目标文件夹（包括NTFS权限和共享权限）
• 超时设置：Lambda默认超时15分钟，若处理大文件，可调整到最大900秒
• 异常处理：要处理网络中断、文件不存在、权限不足等场景，避免函数意外崩溃

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