尝试使用Apache Camel将文件上传到Amazon S3时出错

Question

我正在尝试使用Apache Camel将csv文件从本地目录上载到AWS S3。

参考这里找到的留档（https://camel.apache.org/staging/components/latest/aws-s3-component.html），我试图创建一个简单的路线，就像这样（我当然删除了密钥和其他识别信息，并将其替换为[FAKE_INFO]）：

from("file:fileName=${in.headers[fileName]}")
  .to("aws-s3://[BUCKET]?accessKey=[ACCESS_KEY]&secretKey=RAW([SECRET_KEY])&region=US_EAST_2&prefix=TEST.csv");

这会导致以下错误：

错误：java。lang.IllegalArgumentException:AWS S3密钥头缺少apache camel

在网上搜索了一下之后，我删除了传递的前缀，而是插入了一个。setHeader以这样的方式进行路由：

from("file:fileName=${in.headers[fileName]}")
  .setHeader(S3Constants.KEY, simple("TEST.csv"))
  .to("aws-s3://[BUCKET]?accessKey=[ACCESS_KEY]&secretKey=RAW([SECRET_KEY])&region=US_EAST_2");

这很好，只要我愿意在setHeader之后硬编码所有内容。但是，对于我的特定用例，我需要从exchange标头传递项目，以提供键、bucket name和fileName（多个文件使用此路由，这些文件根据exchange标头中接收到的不同标准，进入不同的bucket）。出于某种原因，只要使用setHeader设置S3常量。键，我再也不能访问任何exchange标头了——事实上，我甚至不能分配S3常量。exchange标头中的键值。正如您所看到的，from部分中的文件名是通过exchange头分配的，我在那里没有遇到任何问题，因此我知道它们正在被路由接收。

关于如何修改此路由，使其允许我在不使用S3常量的情况下上载文件，并在适当的情况下使用exchange标头，有何想法？

Answer 1

不知道我是否理解正确，但在我看来

• 问题主题的问题已经解决了

要定义动态目标地址，有一个“动态到”

.toD(...)

例如，您可以在这样一个动态的目标地址中使用简单的表达式

.toD("aws-s3://${in.header.bucket}?region=${in.header.region}&...")

有关更多详细信息，请参阅Camel文档（“动态到”部分）。

顺便说一句：你写的是“交换头”。不要将Exchange属性与邮件标题混淆！

• Exchange属性仅在Exchange包装器上，因此在骆驼路由完成处理后，Exchange会丢失这些属性