如何检测Azure文件存储中的新文件并触发后续操作？

看起来你之前尝试的两种方法都踩了坑——inotifywait对SMB共享的文件变更支持确实有限，而Logic App里用SFTP连接器去连Azure Files本身就不对路（Azure Files是SMB协议，得用专门的Azure Files连接器）。给你几个靠谱的替代方案，按需选择：

方案1：Azure Event Grid + Azure Function（推荐，实时触发） #

Azure文件存储原生支持通过Event Grid发送文件创建/修改事件，完全可以实现实时触发处理：

1. 在Azure门户里给你的存储账户启用Event Grid（存储账户 -> 事件 -> 启用）；
2. 创建Event Grid订阅，选择你的文件存储作为事件源，事件类型选Microsoft.Storage.FileCreated；
3. 把订阅的端点指向一个Azure Function（比如Python/C# Function）；
4. 在Function里编写逻辑：通过Azure Storage SDK获取新创建的文件，下载到Function的临时目录，然后执行你的操作（比如运行脚本、解析内容等）。

举个Python Function的简单示例（处理文件下载）：

import azure.functions as func
from azure.storage.fileshare import ShareFileClient
import os

def main(event: func.EventGridEvent):
    # 从事件中解析文件信息
    event_data = event.get_json()
    file_url = event_data['url']
    share_name = "your-file-share-name"
    file_path = file_url.split(f"{share_name}/")[-1]

    # 初始化文件客户端
    file_client = ShareFileClient.from_connection_string(
        conn_str=os.environ["STORAGE_CONNECTION_STRING"],
        share_name=share_name,
        file_path=file_path
    )

    # 下载文件到临时目录
    download_file_path = f"/tmp/{file_path.split('/')[-1]}"
    with open(download_file_path, "wb") as download_file:
        download_file.write(file_client.download_file().readall())
    
    # 这里添加你的自定义操作，比如执行脚本
    # os.system(f"python {download_file_path}")

方案2：Azure Automation Runbook（定时轮询，适合简单场景） #

如果不想搞实时触发，用定时轮询也能解决：

1. 创建Azure Automation账户，导入Az.Storage模块；
2. 编写PowerShell Runbook，定时检查文件共享里的新文件（按创建时间筛选）；
3. 把文件下载到Automation沙箱（或者连接到你的VM），执行后续操作；
4. 设置Runbook的触发计划（比如每5分钟运行一次）。

示例PowerShell代码片段：

# 连接到Azure（使用Automation托管身份）
Connect-AzAccount -Identity

# 配置参数
$resourceGroupName = "your-resource-group"
$storageAccountName = "your-storage-account"
$shareName = "your-file-share"
$localDownloadPath = "C:\Temp"
$checkWindowMinutes = 5

# 获取存储账户和文件共享
$storageAccount = Get-AzStorageAccount -ResourceGroupName $resourceGroupName -Name $storageAccountName
$share = Get-AzStorageShare -Context $storageAccount.Context -Name $shareName

# 筛选最近指定时间内创建的文件
$newFiles = Get-AzStorageFile -Share $share -Recurse | Where-Object { 
    $_.GetType().Name -eq "CloudFile" -and $_.Properties.CreationTime -gt (Get-Date).AddMinutes(-$checkWindowMinutes)
}

foreach ($file in $newFiles) {
    # 下载文件到本地路径
    $destPath = Join-Path $localDownloadPath $file.Name
    Get-AzStorageFileContent -Share $share -Path $file.Name -Destination $destPath -Force

    # 执行你的自定义操作，比如运行脚本
    # & $destPath
}

方案3：改进VM映射的定时扫描 #

如果你还是想用VM映射的方式，放弃inotifywait，改用脚本定时扫描共享目录：

• 用PowerShell或者Bash脚本，定时（比如每分钟）检查映射的驱动器里的新文件；
• 比如在Linux VM上用Bash脚本：

#!/bin/bash
SHARE_PATH="/mnt/azurefiles"
PROCESSING_DIR="/local/processing"
CHECK_INTERVAL=60

# 创建处理目录（如果不存在）
mkdir -p $PROCESSING_DIR

while true; do
    # 查找最近1分钟内修改的文件
    find $SHARE_PATH -type f -mmin -1 | while read file; do
        # 复制到本地处理目录
        cp $file $PROCESSING_DIR/
        # 执行自定义操作
        # ./your-processing-script.sh $PROCESSING_DIR/$(basename $file)
    done
    sleep $CHECK_INTERVAL
done

把这个脚本做成系统服务，让它后台运行即可。

另外提一句：之前用Logic App的时候，应该选择Azure Files连接器而不是SFTP连接器，它可以直接连接你的文件存储，监听文件创建事件，然后执行后续动作（比如下载到VM、触发Azure Function等），如果之前选错了连接器可以再试试这个路径。

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