Spring 使用 xml 与 Azure blob 存储集成

Question

使用文件适配器，我有一个以固定速率轮询的入站通道，从目录读取文件，过滤某些文件，最后对它们进行排序并将它们发送到出站网关，出站网关再次移动文件以供服务 bean 处理。

<bean id="baseDirectory" class="java.lang.String">
    <constructor-arg value="${HOME}/user/files/"/>
</bean>

<file:inbound-channel-adapter id="testFiles" directory="#{baseDirectory}" filename-regex="^(test_filename.*)-(\d+)\.csv" comparator="someFileOrderComparator">
    <int:poller fixed-rate="6000"/>
</file:inbound-channel-adapter>

<file:outbound-gateway request-channel="testFiles" reply-channel="testFile" directory="#{baseDirectory}/processing" delete-source-files="true”/>

<int:service-activator input-channel="testFile" ref="someServiceTask" method="executeTask”/>

这是我们如何从文件系统中读取文件的示例。

假设我想从 Azure blob 存储中读取文件，假设我有一个包含文件夹 A 的容器 X。使用帐户名和帐户访问密钥如何告诉 spring Integration 从容器 X 的文件夹 A 中读取文件.

首选 XML 配置。

Answer 1

我遇到了与您面临的问题类似的问题。 这是我解决它的方法 -

1. 创建了一个CloudStorageAccount的bean（你可以很容易地把它转换成xml配置。我不习惯xml配置。） -

   @Bean CloudStorageAccount getAccount(String connString){ return CloudStorageAccount.parse(connString); }

2. 使用 AzureStorageProtocolResolver -

AzureStorageProtocolResolver fileResolver = new AzureStorageProtocolResolver(); File resolvedFile = fileResolver.resolve("azure-blob://<containerName>/<Path to File(e.g. "lib/myfile.jar")>").getFile();

AzureStorageProtocolResolver 是一个 Azure 类，将在内部使用来自 beanfactory 的 StorageAccount bean。 见-https://github.com/Microsoft/spring-cloud-azure/blob/master/spring-cloud-azure-storage/src/main/java/com/microsoft/azure/spring/cloud/storage/AzureStorageProtocolResolver.java

还有另一种方法可以使用 Azure Spring Boot Starter。 见-https://github.com/Microsoft/azure-spring-boot/tree/master/azure-spring-boot-starters/azure-storage-spring-boot-starter