使用 xml Spring 与 Azure blob 存储集成

Question

使用文件适配器，我有一个入站 channel 以固定速率轮询，从目录中读取文件，过滤某些文件，最后对它们进行排序并将它们发送到出站网关，出站网关再次移动文件以供服务 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。使用帐户名和帐户访问 key ，我如何告诉 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