添加Azure存储Blob容器输入绑定Azure函数Java

Question

我有一个EventHubTrighted函数app。下面是方法签名的代码示例：

@functionname（“foo”）@storageaccount（“foostorageRead”）public HttpResponseMessage run(@httptrigger(name=“req”,methods={httpmethod.post},authLevel=authorizationlevel.anonymous）httprequestmessage request,@blobinput(name=“{test1}”,dataType=“String”,path=“blobstorageContainer/{test1}.json”）String test1,

        @BlobInput(
                  name = "test2", 
                  dataType = "string", 
                  path = "blobStorageContainer/{test2}.json") String test2,
       
        final ExecutionContext context) 

我想在方法签名中添加到CloudBlobContainer（上面方法签名中的blobStorageContainer）的输入绑定，这样我就不需要在方法中显式连接到这个容器（因为我需要从这个容器访问更多文件）。在Java中有什么注释/方法可以做到这一点吗？

Answer 1

我跟随博客连接Blob存储容器以获取文件。

请参考下面的代码，使用CloudBlobContainer连接容器，如果新容器不存在于BLOB中，则创建新容器。

CloudStorageAccount storageAccountDest;
CloudBlobClient blobClientDest = null;
CloudBlobContainer containerDest = null;
String storageConnectionStringDest = System.getenv("AzureStorageDemoConnectionStringDest");

// Parse the connection string and create a blob client to interact with Blob
// storage
storageAccountDest = CloudStorageAccount.parse(storageConnectionStringDest);
blobClientDest = storageAccountDest.createCloudBlobClient();  
containerDest = blobClientDest.getContainerReference("files2");

// Create the container if it does not exist with public access.
context.getLogger().info("Creating container: " + containerDest.getName());
containerDest.createIfNotExists(BlobContainerPublicAccessType.CONTAINER, new BlobRequestOptions(),
new OperationContext());
CloudBlob blobDest = containerDest.getBlockBlobReference(filename);
try {
    context.getLogger().info("Start Uploading blob: " + filename);
    blobDest.uploadFromByteArray(content, 0, content.length);
    context.getLogger().info("Finished Uploading blob: " + filename);
} 
catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}

请看一下这里