使用Java的Azure函数——如何创建@BlobTrigger

Question

我需要使用Java创建Azure函数BlobTrigger来监视我的存储容器中是否有新的和更新的blob。

使用以下代码尝试

import java.util.*;
import com.microsoft.azure.serverless.functions.annotation.*;
import com.microsoft.azure.serverless.functions.*;
import java.nio.file.*;
import java.io.*;
import java.net.URL;
import java.net.URLConnection;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import com.microsoft.azure.storage.*;
import com.microsoft.azure.storage.blob.*;

@FunctionName("testblobtrigger")
 public String testblobtrigger(@BlobTrigger(name = "test", path = "testcontainer/{name}") String content) {
     try {
         return String.format("Blob content : %s!", content);

     } catch (Exception e) {
         // Output the stack trace.
         e.printStackTrace();
         return "Access Error!";
     }
 }

执行时，它显示错误

存储绑定（blob/队列/表）必须具有非空连接。在方法上发现无效的存储绑定：

当添加连接字符串时，它正在工作

public String kafkablobtrigger(@BlobTrigger(name = "test", path = "testjavablobstorage/{name}",connection=storageConnectionString) String content) {

为什么我在使用blobtrigger时需要添加连接字符串？

在C#中，它在没有连接字符串的情况下工作：

public static void ProcessBlobContainer1([BlobTrigger("container1/{blobName}")] CloudBlockBlob blob, string blobName)
{
    ProcessBlob("container1", blobName, blob);
}

我没有看到任何Azure函数的Java示例@BlobTrigger。

Answer 1

毕竟，< code>connection是触发器识别容器位置所必需的。

经过测试，我发现@Mikhail是对的。对于C#，如果忽略< code>connection,将使用默认值(在local.settings.json或portal的应用程序设置中)。但不幸的是，java没有相同的设置。

您可以在@FuncionName下方添加@StorageAccount（“YourStorageConnection”），因为这是另一种有效的选择方式。YourStorageConnection 在 local.settings.json 或门户的应用程序设置中的价值取决于您。

您可以按照本教程，使用mvn azure-function： add查找java的四个（Http/Blob/Queue/TimerTrigger）模板。