Azure Functions Java中BlobTrigger触发后删除源Blob文件方法问询

要实现Blob处理完成后删除源Blob，你可以通过Azure Storage Blob SDK直接操作存储账户，具体步骤如下：

1. 添加依赖 #

首先在你的Maven项目pom.xml中添加Azure Storage Blob SDK的依赖（使用最新稳定版即可）：

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-storage-blob</artifactId>
    <version>12.25.0</version>
</dependency>

2. 在函数中实现删除逻辑 #

结合你提供的现有代码，补充删除Blob的逻辑，完整代码如下：

import com.azure.storage.blob.BlobClient;
import com.azure.storage.blob.BlobContainerClient;
import com.azure.storage.blob.BlobServiceClient;
import com.azure.storage.blob.BlobServiceClientBuilder;
import com.microsoft.azure.functions.*;
import com.microsoft.azure.functions.annotation.BlobTrigger;
import com.microsoft.azure.functions.annotation.BindingName;
import com.microsoft.azure.functions.annotation.FunctionName;

@FunctionName("import-import")
public void run(
        @BlobTrigger(
                name = "import",
                dataType = "binary",
                path = "import/containers/{name}",
                connection = "SourceStorage"
        ) final byte[] content,
        @BindingName("name") final String filename,
        final ExecutionContext context
) {
    final Logger logger = context.getLogger();
    
    // 从函数配置中读取存储账户连接字符串
    String connectionString = System.getenv("SourceStorage");
    if (connectionString == null || connectionString.isEmpty()) {
        logger.severe("未找到SourceStorage连接字符串配置");
        return;
    }

    try {
        // 创建Blob服务客户端、容器客户端
        BlobServiceClient blobServiceClient = new BlobServiceClientBuilder()
                .connectionString(connectionString)
                .build();
        // 注意：你的BlobTrigger路径中，"import"是容器名，"containers/{name}"是Blob的完整路径
        BlobContainerClient containerClient = blobServiceClient.getBlobContainerClient("import");
        BlobClient blobClient = containerClient.getBlobClient("containers/" + filename);

        // 执行删除操作
        if (blobClient.exists()) {
            blobClient.delete();
            logger.info("已成功删除Blob: " + filename);
        } else {
            logger.warning("要删除的Blob不存在: " + filename);
        }
    } catch (Exception e) {
        logger.severe("删除Blob时出错: " + e.getMessage());
        e.printStackTrace();
    }
}

关键注意事项 #

• 路径匹配：你的BlobTrigger路径为import/containers/{name}，其中import是存储容器名，containers/{name}是Blob的完整相对路径，创建BlobClient时要确保路径拼接正确。
• 权限校验：确保SourceStorage对应的连接字符串拥有Blob的删除权限（推荐使用存储账户访问密钥或带删除权限的SAS令牌）。
• 异常处理：添加异常捕获逻辑，避免删除失败导致函数执行中断。

内容的提问来源于stack exchange，提问作者D.S.