我如何在 Java 中使用 azure 函数的 blob 存储
How can i use blob storage from an azure function in Java
我有一个 http 触发的 azure 函数（用 Java 编写），我想在其中访问 Blob 存储。代码在 Maven 下编译，但是当我在本地 运行 并从 CURL 发送 post 时，运行time 由于缺少 com.microsoft.azure.storage.CloudStorageAccount 导致的 ClassNotFound 异常而崩溃。 azure-storage（版本 6.0.0）在 POM 文件中列为依赖项。相关的 .jar 文件应该放在哪里才能被函数看到？
如有任何关于 Java azure 函数的见解，我们将不胜感激。
您能否分享有关您使用的方法和类型的任何详细信息？要进行输出绑定，您需要使用带有正确注释的 OutputBinding<T> class。这是我刚刚测试过的与您提到的类似的示例：
@FunctionName("hello")
public String hello(
@HttpTrigger(name = "req", methods = {
"post" }, authLevel = AuthorizationLevel.ANONYMOUS) String req,
ExecutionContext context, @BlobOutput(name = "blob", connection = "StorageAccount", path = "test/foo.txt")OutputBinding<String> blob)
{
blob.setValue("hello world");
return String.format("Hello, %s!", req);
}
注意@BlobOutput 属性和 OutputBinding 类型（可以是 String 或 byte []，但我相信如果执行 byte []，您还需要将数据类型设置为 "binary" 在@BlobAttribute 上。
如果可行请告诉我
根据您的需要，我建议您按照此official tutorial创建、运行并部署您的java azure function。
函数Class:
package com.fabrikam.functions;
import com.microsoft.azure.serverless.functions.annotation.*;
import com.microsoft.azure.serverless.functions.ExecutionContext;
import com.microsoft.azure.storage.*;
import com.microsoft.azure.storage.blob.*;
/**
* Hello function with HTTP Trigger.
*/
public class Function {
// Configure the connection-string with your values
public static final String storageConnectionString =
"DefaultEndpointsProtocol=http;" +
"AccountName=***;" +
"AccountKey=***";
@FunctionName("hello")
public String hello(@HttpTrigger(name = "req", methods = {"get", "post"}, authLevel = AuthorizationLevel.ANONYMOUS) String req,
ExecutionContext context) {
try {
// Retrieve storage account from connection-string.
CloudStorageAccount storageAccount = CloudStorageAccount.parse(storageConnectionString);
// Create the blob client.
CloudBlobClient blobClient = storageAccount.createCloudBlobClient();
// Get a reference to a container.
// The container name must be lower case
CloudBlobContainer container = blobClient.getContainerReference(req);
// Create the container if it does not exist.
container.createIfNotExists();
return String.format("Hello, I get container name : %s!", container.getName());
} catch (Exception e) {
// Output the stack trace.
e.printStackTrace();
return "Access Error!";
}
}
}
Pom.xml：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.fabrikam.functions</groupId>
<artifactId>fabrikam-functions</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<name>Azure Java Functions</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
<functionAppName>fabrikam-functions-20171017112209094</functionAppName>
</properties>
<dependencies>
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-functions-java-core</artifactId>
<version>1.0.0-beta-1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.microsoft.azure/azure-storage -->
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-storage</artifactId>
<version>6.0.0</version>
</dependency>
<!-- Test -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<pluginManagement>
<plugins>
<plugin>
<artifactId>maven-resources-plugin</artifactId>
<version>3.0.2</version>
</plugin>
<plugin>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-functions-maven-plugin</artifactId>
<version>0.1.4</version>
</plugin>
</plugins>
</pluginManagement>
<plugins>
<plugin>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-functions-maven-plugin</artifactId>
<configuration>
<resourceGroup>java-functions-group</resourceGroup>
<appName>${functionAppName}</appName>
<region>westus2</region>
<appSettings>
<property>
<name>FUNCTIONS_EXTENSION_VERSION</name>
<value>beta</value>
</property>
</appSettings>
</configuration>
<executions>
<execution>
<id>package-functions</id>
<goals>
<goal>package</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<artifactId>maven-resources-plugin</artifactId>
<executions>
<execution>
<id>copy-resources</id>
<phase>package</phase>
<goals>
<goal>copy-resources</goal>
</goals>
<configuration>
<overwrite>true</overwrite>
<outputDirectory>${project.build.directory}/azure-functions/${functionAppName}
</outputDirectory>
<resources>
<resource>
<directory>${project.basedir}</directory>
<includes>
<include>host.json</include>
<include>local.settings.json</include>
</includes>
</resource>
</resources>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
然后使用命令mvn clean package将你的maven项目打包成jar包
使用命令 mvn azure-functions:run 在本地 运行 您的 azure 函数。
更新答案：
我 运行 我的 azure 函数并重现与您所说的相同的异常。
java.lang.NoClassDefFoundError:
com/microsoft/azure/storage/CloudStorageAccount
Exception:
Stack: java.lang.reflect.InvocationTargetException
[10/25/2017 2:48:44 AM] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
[10/25/2017 2:48:44 AM] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
[10/25/2017 2:48:44 AM] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[10/25/2017 2:48:44 AM] at java.lang.reflect.Method.invoke(Method.java:498)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.broker.JavaMethodInvokeInfo.invoke(JavaMethodInvokeInfo.java:19)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.broker.JavaMethodExecutor.execute(JavaMethodExecutor.java:34)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.broker.JavaFunctionBroker.invokeMethod(JavaFunctionBroker.java:40)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.handler.InvocationRequestHandler.execute(InvocationRequestHandler.java:33)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.handler.InvocationRequestHandler.execute(InvocationRequestHandler.java:10)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.handler.MessageHandler.handle(MessageHandler.java:41)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.JavaWorkerClient$StreamingMessagePeer.lambda$onNext[=12=](JavaWorkerClient.java:84)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinTask$AdaptedRunnableAction.exec(ForkJoinTask.java:1386)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
[10/25/2017 2:48:44 AM] Caused by: java.lang.NoClassDefFoundError: com/microsoft/azure/storage/CloudStorageAccount
[10/25/2017 2:48:44 AM] at com.fabrikam.functions.Function.hello(Function.java:26)
[10/25/2017 2:48:44 AM] ... 16 more
[10/25/2017 2:48:44 AM] Caused by: java.lang.ClassNotFoundException: com.microsoft.azure.storage.CloudStorageAccount
[10/25/2017 2:48:44 AM] at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
[10/25/2017 2:48:44 AM] at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
[10/25/2017 2:48:44 AM] at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
[10/25/2017 2:48:44 AM] ... 17 more
[10/25/2017 2:48:44 AM] .
[10/25/2017 2:48:44 AM] Function had errors. See Azure WebJobs SDK dashboard for details. Instance ID is '3450abda-99a0-4d75-add2-a7bc48a0cb51'
[10/25/2017 2:48:44 AM] System.Private.CoreLib: Exception while executing function: Functions.hello. System.Private.CoreLib: Result:
研究了一下，发现是因为jar打包后没有dependent jar packages。
所以，我将如下配置片段添加到我的 pom.xml
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<configuration>
<descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs>
<archive>
<manifest>
<mainClass>Your main class path</mainClass>
</manifest>
</archive>
</configuration>
<executions>
<execution>
<id>make-assembly</id>
<phase>package</phase>
<goals>
<goal>single</goal>
</goals>
</execution>
</executions>
</plugin>
然后请使用命令mvn-clean-package，你会看到生成了两个jar文件。
一个是不包含dependent jar packages，第二个是包含dependent jar packages.
将fabrikam-functions-1.0-SNAPSHOT-jar-with-dependenciesjar移动到路径：${project.basedir}/target/azure-functions/${function-app-name}/
对我来说，它看起来像 E:\TestAzureFunction\fabrikam-functions\target\azure-functions\fabrikam-functions-20171017112209094。
不要忘记将 jar 重命名为 fabrikam-functions-1.0-SNAPSHOT。
最后，我运行 azure函数成功通过url得到输出结果：http://localhost:7071/api/mongo.
此外，您可以参考这个github doc了解更多关于azure的配置细节function maven plugin。
希望对你有帮助。
我有一个 http 触发的 azure 函数（用 Java 编写），我想在其中访问 Blob 存储。代码在 Maven 下编译，但是当我在本地 运行 并从 CURL 发送 post 时，运行time 由于缺少 com.microsoft.azure.storage.CloudStorageAccount 导致的 ClassNotFound 异常而崩溃。 azure-storage（版本 6.0.0）在 POM 文件中列为依赖项。相关的 .jar 文件应该放在哪里才能被函数看到？
如有任何关于 Java azure 函数的见解，我们将不胜感激。
您能否分享有关您使用的方法和类型的任何详细信息？要进行输出绑定，您需要使用带有正确注释的 OutputBinding<T> class。这是我刚刚测试过的与您提到的类似的示例：
@FunctionName("hello")
public String hello(
@HttpTrigger(name = "req", methods = {
"post" }, authLevel = AuthorizationLevel.ANONYMOUS) String req,
ExecutionContext context, @BlobOutput(name = "blob", connection = "StorageAccount", path = "test/foo.txt")OutputBinding<String> blob)
{
blob.setValue("hello world");
return String.format("Hello, %s!", req);
}
注意@BlobOutput 属性和 OutputBinding 类型（可以是 String 或 byte []，但我相信如果执行 byte []，您还需要将数据类型设置为 "binary" 在@BlobAttribute 上。
如果可行请告诉我
根据您的需要，我建议您按照此official tutorial创建、运行并部署您的java azure function。
函数Class:
package com.fabrikam.functions;
import com.microsoft.azure.serverless.functions.annotation.*;
import com.microsoft.azure.serverless.functions.ExecutionContext;
import com.microsoft.azure.storage.*;
import com.microsoft.azure.storage.blob.*;
/**
* Hello function with HTTP Trigger.
*/
public class Function {
// Configure the connection-string with your values
public static final String storageConnectionString =
"DefaultEndpointsProtocol=http;" +
"AccountName=***;" +
"AccountKey=***";
@FunctionName("hello")
public String hello(@HttpTrigger(name = "req", methods = {"get", "post"}, authLevel = AuthorizationLevel.ANONYMOUS) String req,
ExecutionContext context) {
try {
// Retrieve storage account from connection-string.
CloudStorageAccount storageAccount = CloudStorageAccount.parse(storageConnectionString);
// Create the blob client.
CloudBlobClient blobClient = storageAccount.createCloudBlobClient();
// Get a reference to a container.
// The container name must be lower case
CloudBlobContainer container = blobClient.getContainerReference(req);
// Create the container if it does not exist.
container.createIfNotExists();
return String.format("Hello, I get container name : %s!", container.getName());
} catch (Exception e) {
// Output the stack trace.
e.printStackTrace();
return "Access Error!";
}
}
}
Pom.xml：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.fabrikam.functions</groupId>
<artifactId>fabrikam-functions</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<name>Azure Java Functions</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
<functionAppName>fabrikam-functions-20171017112209094</functionAppName>
</properties>
<dependencies>
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-functions-java-core</artifactId>
<version>1.0.0-beta-1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.microsoft.azure/azure-storage -->
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-storage</artifactId>
<version>6.0.0</version>
</dependency>
<!-- Test -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<pluginManagement>
<plugins>
<plugin>
<artifactId>maven-resources-plugin</artifactId>
<version>3.0.2</version>
</plugin>
<plugin>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-functions-maven-plugin</artifactId>
<version>0.1.4</version>
</plugin>
</plugins>
</pluginManagement>
<plugins>
<plugin>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-functions-maven-plugin</artifactId>
<configuration>
<resourceGroup>java-functions-group</resourceGroup>
<appName>${functionAppName}</appName>
<region>westus2</region>
<appSettings>
<property>
<name>FUNCTIONS_EXTENSION_VERSION</name>
<value>beta</value>
</property>
</appSettings>
</configuration>
<executions>
<execution>
<id>package-functions</id>
<goals>
<goal>package</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<artifactId>maven-resources-plugin</artifactId>
<executions>
<execution>
<id>copy-resources</id>
<phase>package</phase>
<goals>
<goal>copy-resources</goal>
</goals>
<configuration>
<overwrite>true</overwrite>
<outputDirectory>${project.build.directory}/azure-functions/${functionAppName}
</outputDirectory>
<resources>
<resource>
<directory>${project.basedir}</directory>
<includes>
<include>host.json</include>
<include>local.settings.json</include>
</includes>
</resource>
</resources>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
然后使用命令mvn clean package将你的maven项目打包成jar包
使用命令 mvn azure-functions:run 在本地 运行 您的 azure 函数。
更新答案：
我 运行 我的 azure 函数并重现与您所说的相同的异常。
java.lang.NoClassDefFoundError: com/microsoft/azure/storage/CloudStorageAccount
Exception:
Stack: java.lang.reflect.InvocationTargetException
[10/25/2017 2:48:44 AM] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
[10/25/2017 2:48:44 AM] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
[10/25/2017 2:48:44 AM] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[10/25/2017 2:48:44 AM] at java.lang.reflect.Method.invoke(Method.java:498)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.broker.JavaMethodInvokeInfo.invoke(JavaMethodInvokeInfo.java:19)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.broker.JavaMethodExecutor.execute(JavaMethodExecutor.java:34)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.broker.JavaFunctionBroker.invokeMethod(JavaFunctionBroker.java:40)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.handler.InvocationRequestHandler.execute(InvocationRequestHandler.java:33)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.handler.InvocationRequestHandler.execute(InvocationRequestHandler.java:10)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.handler.MessageHandler.handle(MessageHandler.java:41)
[10/25/2017 2:48:44 AM] at com.microsoft.azure.webjobs.script.JavaWorkerClient$StreamingMessagePeer.lambda$onNext[=12=](JavaWorkerClient.java:84)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinTask$AdaptedRunnableAction.exec(ForkJoinTask.java:1386)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[10/25/2017 2:48:44 AM] at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
[10/25/2017 2:48:44 AM] Caused by: java.lang.NoClassDefFoundError: com/microsoft/azure/storage/CloudStorageAccount
[10/25/2017 2:48:44 AM] at com.fabrikam.functions.Function.hello(Function.java:26)
[10/25/2017 2:48:44 AM] ... 16 more
[10/25/2017 2:48:44 AM] Caused by: java.lang.ClassNotFoundException: com.microsoft.azure.storage.CloudStorageAccount
[10/25/2017 2:48:44 AM] at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
[10/25/2017 2:48:44 AM] at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
[10/25/2017 2:48:44 AM] at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
[10/25/2017 2:48:44 AM] ... 17 more
[10/25/2017 2:48:44 AM] .
[10/25/2017 2:48:44 AM] Function had errors. See Azure WebJobs SDK dashboard for details. Instance ID is '3450abda-99a0-4d75-add2-a7bc48a0cb51'
[10/25/2017 2:48:44 AM] System.Private.CoreLib: Exception while executing function: Functions.hello. System.Private.CoreLib: Result:
研究了一下，发现是因为jar打包后没有dependent jar packages。
所以，我将如下配置片段添加到我的 pom.xml
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<configuration>
<descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs>
<archive>
<manifest>
<mainClass>Your main class path</mainClass>
</manifest>
</archive>
</configuration>
<executions>
<execution>
<id>make-assembly</id>
<phase>package</phase>
<goals>
<goal>single</goal>
</goals>
</execution>
</executions>
</plugin>
然后请使用命令mvn-clean-package，你会看到生成了两个jar文件。
一个是不包含dependent jar packages，第二个是包含dependent jar packages.
将fabrikam-functions-1.0-SNAPSHOT-jar-with-dependenciesjar移动到路径：${project.basedir}/target/azure-functions/${function-app-name}/
对我来说，它看起来像 E:\TestAzureFunction\fabrikam-functions\target\azure-functions\fabrikam-functions-20171017112209094。
不要忘记将 jar 重命名为 fabrikam-functions-1.0-SNAPSHOT。
最后，我运行 azure函数成功通过url得到输出结果：http://localhost:7071/api/mongo.
此外，您可以参考这个github doc了解更多关于azure的配置细节function maven plugin。
希望对你有帮助。