弹簧集成 S3 'beanName'不得为空



我正在尝试使用S3入站通道适配器从S3下载文件。这是我的配置:

s3.xml:
<int:chain input-channel="s3ReaderChannel" output-channel="uncompressPayloadChannel">
 <int:service-activator ref="s3Bean" method="generateS3ObjectHash" />
 <int-aws:s3-inbound-channel-adapter 
               bucket="${s3.bucket}"
               session-factory="s3SessionFactory"
               auto-create-local-directory="true"
               auto-startup="false"
               filename-pattern="*.gz"
               local-directory="."
               local-filename-generator-expression="#this"
               temporary-file-suffix=".transffering"
               remote-directory="/remote/mytransfers"
               local-filter="acceptAllFilter"/>
</int:chain>
<bean id="s3SessionFactory" 
class="org.springframework.integration.aws.support.S3SessionFactory"/>


aws-credentials.xml:
<!-- Define global credentials for all the AWS clients -->
<aws-context:context-credentials>
<aws-context:instance-profile-credentials/>
<aws-context:simple-credentials access-key="${aws.accesskey}"
                                secret-key="${aws.secretkey}"/>
</aws-context:context-credentials>
<!-- Define global region -->
<aws-context:context-region region="${aws.region}"/>

当我尝试执行时,我会得到:

Exception in thread "main"` 
`org.springframework.beans.factory.BeanDefinitionStoreException: Unexpected 
exception parsing XML document from file`; nested exception is 
java.lang.IllegalArgumentException: 'beanName' must not be empty
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:414)
at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:336)
...30 more
Caused by: java.lang.IllegalArgumentException: 'beanName' must not be empty
at org.springframework.util.Assert.hasText(Assert.java:181)
at org.springframework.beans.factory.config.RuntimeBeanReference.<init>(RuntimeBeanReference.java:58)
at org.springframework.beans.factory.config.RuntimeBeanReference.<init>(RuntimeBeanReference.java:46)
at org.springframework.beans.factory.support.BeanDefinitionBuilder.addPropertyReference(BeanDefinitionBuilder.java:226)
at org.springframework.integration.config.xml.AbstractPollingInboundChannelAdapterParser.doParse(AbstractPollingInboundChannelAdapterParser.java:64)
   ...20 more
`

从堆栈跟踪中,AbstractPollingInboundChannelAdapterParser.java:64是关于OutputChannel的,因为它在链中,所以我不明白。

我在这里缺少什么?

正确,入站通道适配器是流的开始,并且根本无法在<chain>中声明。更多的是,您会像您在<int:service-activator>之后声明那样乱七八糟。

您必须将<int-aws:s3-inbound-channel-adapter>移动到<chain>之外,并请记住,这将是您的流程的开始。

我不确定是什么让您认为错误的方式,但看起来您需要参考手册中的更多信息。

最新更新