问题标签 [apache-camel-aws]

我是 Apache Camel 的新手。我想访问通过发布请求发送的数据，以便从 S3 下载文件。这是我写的路由器。

将要发送的对应json数据->

如何在上面的代码中访问这些 json 值？

我对休息骆驼组件的发布请求的正文不是 json 的形式。因此我无法提取键值对。如何将正文转换为 json？我发送了一个这种类型的 json 对象

我必须使用这个 json 数据从 AWS S3 下载文件。骆驼中对应的路线是：

这里$body[filename]结果是 null 因为$body不是 json 对象。如何将其转换为 json 对象？

我有一个使用 apache camel 的 rest api。当我在路由上发出发布请求时，它应该从 S3 获取文件并将文件的内容作为响应发送回来。我正在发送 json data(filename, bucketName, accesskey, secretkey, region) 以便从 s3 中提取文件。我能够提取文件，但我不知道如何将文件的内容作为响应发回。截至目前，我可以将其下载到我的本地目录。

现在，.to("file:/tmp/")我不想将文件的内容作为响应发送回来。我怎么能在 apache 骆驼中做到这一点？

我尝试为我的 aws-s3 消费者端点应用前缀和分隔符。由于某种原因，分隔符参数无法识别：

org.apache.camel.ResolveEndpointFailedException：无法解析端点：aws-s3://somebucketname?accessKey=RAW(xxxxxx)& delimiter=%2F &prefix=somePrefix&secretKey=RAW(xxxxx) 由于：有 1 个参数不能' t 设置在端点上。如果参数拼写正确并且它们是端点的属性，请检查 uri。未知参数=[{delimiter=/}]

我认为也许调整 &delimiter=RAW(/) 会有所帮助，但我有相同的结果：

用例：当用户点击端点时，我们生成一个 csv 文件，我们希望将其上传到不同的源（FTP 和 S3）。我们需要在上传之前对文件进行加密和转换。以下是路线的样子（过于简化）：

FTP 路由：

S3路线：

工作原理：S3 和 SFTP 上传路由正常工作。

要求：

1. 如果代码可以共享就太好了。两条路线中都可能存在一些不同的参数/处理器。
2. 两个路由都执行后需要删除文件。
3. 我们需要在上传后终止路由，因为每个请求都有不同的文件名。
4. 以上两条路线不能合并为一条，因为实际路线中有太多的 if-else 条件，这会使情况更加复杂。
5. 路由应该是可选的（例如，选择上传到 s3/sftp 或两者都应该可用）

我试过的：

1. Camel Direct：它有助于代码重用，但它不允许多个消费者（在我的情况下这两条路线）
2. Camel Seda：它允许多个消费者，但似乎不允许同步路由。
3. 删除骆驼上下文之外的文件。这是一个问题，因为我们不知道上传文件需要多少时间。

环境：
Camel 3.4.3、Spring Boot 2.2.3、Java8、

我正在尝试在我们的融合环境中定义一个 Camel S3 源连接器。

这是我正在使用的配置

这是我收到的错误，当我尝试定义连接器时

上述错误的原因是什么？

有人告诉我，由于连接服务器是一个 ec2 实例，我不必在这里定义 AWS 参数。那是对的吗？

谢谢

注意：想要补充一下，有两个连接服务器，并且输出中仅显示其中一个错误

我正在尝试定义 Camel S3 Source 连接器。我进行了相当多的搜索，但没有成功找到以下问题的答案。

• 如何设置我的连接器，以便 S3 存储桶中的文件在处理后不会被删除，但可以移动到我指定的另一个文件夹
• 是否可以为同一个存储桶定义具有不同值转换器的单独连接器，也许是通过存储桶下的文件夹？连接器将根据文件类型使用不同的 kafka 主题。定义连接器属性时如何定义带有文件夹的存储桶

谢谢

我正在使用我们的 Confluent (5.5.1) 安装定义 Camel S3 Source 连接器。创建连接器并将状态检查为“正在运行”后，我将文件上传到我的 S3 存储桶。即使我对存储桶进行 ls 操作，它也是空的，这表明该文件已被处理和删除。但是，我没有看到该主题中的消息。我基本上按照这个示例尝试一个简单的 4 行文件，而不是独立的 kafka，而是在一个融合集群上执行它。

这是我的配置

我在日志中看到了这些错误

如果我对连接器的状态进行 curl 请求，我会收到此状态错误

我在几个链接中看到了以下解决方案，但这也没有帮助。它建议在配置中添加以下键

谢谢

更新

我将配置削减到最小，但仍然得到相同的错误

仍然得到同样的错误

不知道我还应该在哪里寻找根本原因

我有一个 SQS 队列。我希望实现的目标是根据消息属性过滤消息，如果它与过滤条件匹配，则将其删除。所以我在Java中有一个看起来像这样的函数

发布这个我正在调用这个函数

看起来正在构建的路线无法删除该消息。

首先，我使用 WSDL 文件使用 jsonschema2pojo 插件生成了 pojo 类。

我的 WSDL 文件包含标题和正文。

Body Root Pojo 看起来像这样：

标题如下所示：

现在在骆驼的一个进程类中，我将SubmitCustomerOrderRequest（这里这个pojo只考虑正文而不是标题）放入正文中，如下所示：

现在在路线中，我正在使用这个概念进行编组

并像这样编组到 xml 中：

现在这里的问题是，它生成xml但没有header，如何在流程类中也包含header，以便在转换为xml时，它生成的header也带有body

它的生成是这样的：

而我需要这样的标题：

任何帮助都是不言而喻的。