问题标签 [apache-camel-aws]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
919 浏览

java - 如何使用 camel-aws 向 amazonSQS 发送消息 MessageGroupID 和 MessageDeduplicationID

我们能否使用 Java-DSL 语法向 Amazon SQS“FIFO”队列发送消息:

请记住:这是一个 FIFO 队列,因此它需要 MessageGroupID 和 MessageDeduplicationID。

0 投票
0 回答
775 浏览

java - 如何用骆驼从http下载zip文件?

我是骆驼的初学者。我正在尝试下载一个具有 http 路径的 zip 文件,并尝试将文件存储在本地文件系统中。我设法读取了该文件,但不是读取一次并将其下载到本地文件夹中,而是我的代码运行到无限循环并创建了该文件的许多副本,因此我得到了 OutOfMemoryError。我做了调查,使用定时器组件应该可以解决问题,但我不知道如何一起使用定时器组件和直接组件......我尝试了以下代码,但没有任何反应

这是我的代码:

0 投票
0 回答
442 浏览

apache-camel - Camel SNS - 如何在不阻塞的情况下使用异步客户端?

在 Camel 中,当使用AmazonSNSAsync客户端发送到 SNS 端点时,发布行为似乎没有改变,因为底层SnsPublisher仍然调用阻塞同步getSNSClient().publish(request)方法。

是否可以异步发布,以免调用者被迫等待响应?

这里提到synchronous标志可能是相关的,但在查看源代码后我没有看到它被使用。

0 投票
2 回答
1054 浏览

java - 我如何使用 apache-camel 在一次轮询中从 aws s3 目录中读取所有文件

我试图实现:

  1. 从 s3 目录中读取所有文件。
  2. 将所有文件复制到 s3 上的备份目录。
  3. 将所有文件内容聚合到一个文件中,并将其复制到 s3 上的另一个目录。

但我坚持在一次民意调查中阅读所有文件的第一点。

my from router : aws-s3://${camel.bucket.name}?amazonS3Client=#s3Client&prefix=some_path_on_s3&deleteAfterRead=true&delay=100s

有没有办法在一次轮询中从 s3 目录中获取所有文件?

0 投票
0 回答
130 浏览

apache-camel - 如何为基于流程图的执行过程实现 Apache Camel 动态路由器模式

在此处输入图像描述如何实现 Apache Camel 动态路由器模式,用于基于流程图的执行过程。我已经通过链接https://www.javainuse.com/camel/camel-dynamic-router-example,无法弄清楚。

我想创建一个处理所有三个步骤的 API。

1)首先在内部命中另一个API并获取响应并将其响应转移到下一个阶段,即Database

2)第二步将对DB执行写操作并路由到不同的阶段,即Response Handler

总结上面的流程,我要做的是为每个阶段创建不同的路由,并以流程定义的方式触发或执行。

0 投票
1 回答
435 浏览

amazon-s3 - Camel AWS-S3 - 并非所有字节都从 S3ObjectInputStream 中读取,因此中止 HTTP 连接

我正在使用 camel-aws 将文件轮询到远程 S3 存储桶以检查它是否已到达。我对文件的内容不感兴趣。

我已将 includeBody 设置为 false 以不读取文件的内容,但是我收到以下警告:

0 投票
1 回答
323 浏览

amazon-s3 - Camel S3:在调度程序关闭的情况下列出 S3 存储桶文件

我正在遵循 Camel 路线,它试图从 S3 存储桶中读取文件列表:

然而,这条路线被每分钟运行的外部调度程序调用。看起来 Camel-S3 组件的默认行为是使用调度程序运行,但这会导致相同的文件被一次又一次地处理。

我尝试使用 startScheduler=false 关闭 Camel-S3 调度程序,但是当外部调度程序启动并获取“$ {header.CamelAwsS3Key}”的空值时,这不会执行“aws-s3”部分。

是否可以在没有内部调度程序的情况下运行此组件?

正在使用的骆驼版本 - 2.22.0

用于 aws 的依赖项:

0 投票
1 回答
408 浏览

apache-camel - 使用骆驼从 S3 存储桶中读取文件

我是骆驼的新手,需要一些指导。我需要从 S3 存储桶中读取一些文件。结构是这样的。

当一个特定的excel文件被放入incoming/xls文件夹(比如file1.xls)时,我需要提取所有文件,进行一些处理并将它们放入具有相同目录结构的已处理文件夹中。

我需要为此使用哪些组件?我尝试阅读文档,但有点难以弄清楚我需要哪些组件。我知道我将使用 camel-aws-s3 插件,但那里没有很多示例。

0 投票
1 回答
1391 浏览

amazon-web-services - 在 AWS 中托管 Apache Camel 的最佳方式是什么?

当我们将工作负载转移到 AWS 时,我正在寻找一种广泛使用并具有适当连接器的 ETL 工具 - Apache Camel 似乎符合要求。但是,我很难找到有关如何在 AWS 中部署 Camel 的信息 - 显而易见的是在 EC2 实例上,但我们希望避免虚拟机所需的设置和维护。我没有看到有人将它作为托管服务提供,所以我想探索的选项是将它作为 ECS 中的容器运行,因为我们将运行许多其他容器。

容器似乎不是Apache Camel 网站上的安装选项- 也许它对于旨在连接到其他所有东西的工具来说太有限了?

在容器中运行 Camel 是否可以接受且实用,我在哪里可以找到有关它的更多信息?

0 投票
0 回答
43 浏览

amazon-web-services - 如何在骆驼的休息组件中执行from语句?

我为此使用 apache camel。我有一个 http 服务器。当我对 url 执行 get 请求时,它应该从 aws s3 中的存储桶中获取文件,然后在我的本地目录中创建一个文件。

我为此编写了上面的代码,但看起来它忽略了“from”语句并直接执行“to”语句,因此在我的 tmp 目录中创建了一个空文件。还有其他方法可以做到这一点吗?