问题标签 [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.
java - 如何使用 camel-aws 向 amazonSQS 发送消息 MessageGroupID 和 MessageDeduplicationID
我们能否使用 Java-DSL 语法向 Amazon SQS“FIFO”队列发送消息:
请记住:这是一个 FIFO 队列,因此它需要 MessageGroupID 和 MessageDeduplicationID。
java - 如何用骆驼从http下载zip文件?
我是骆驼的初学者。我正在尝试下载一个具有 http 路径的 zip 文件,并尝试将文件存储在本地文件系统中。我设法读取了该文件,但不是读取一次并将其下载到本地文件夹中,而是我的代码运行到无限循环并创建了该文件的许多副本,因此我得到了 OutOfMemoryError。我做了调查,使用定时器组件应该可以解决问题,但我不知道如何一起使用定时器组件和直接组件......我尝试了以下代码,但没有任何反应
这是我的代码:
apache-camel - Camel SNS - 如何在不阻塞的情况下使用异步客户端?
在 Camel 中,当使用AmazonSNSAsync
客户端发送到 SNS 端点时,发布行为似乎没有改变,因为底层SnsPublisher
仍然调用阻塞同步getSNSClient().publish(request)
方法。
是否可以异步发布,以免调用者被迫等待响应?
这里提到的synchronous
标志可能是相关的,但在查看源代码后我没有看到它被使用。
java - 我如何使用 apache-camel 在一次轮询中从 aws s3 目录中读取所有文件
我试图实现:
- 从 s3 目录中读取所有文件。
- 将所有文件复制到 s3 上的备份目录。
- 将所有文件内容聚合到一个文件中,并将其复制到 s3 上的另一个目录。
但我坚持在一次民意调查中阅读所有文件的第一点。
my from router :
aws-s3://${camel.bucket.name}?amazonS3Client=#s3Client&prefix=some_path_on_s3&deleteAfterRead=true&delay=100s
有没有办法在一次轮询中从 s3 目录中获取所有文件?
apache-camel - 如何为基于流程图的执行过程实现 Apache Camel 动态路由器模式
如何实现 Apache Camel 动态路由器模式,用于基于流程图的执行过程。我已经通过链接https://www.javainuse.com/camel/camel-dynamic-router-example,无法弄清楚。
我想创建一个处理所有三个步骤的 API。
1)首先在内部命中另一个API并获取响应并将其响应转移到下一个阶段,即Database
2)第二步将对DB执行写操作并路由到不同的阶段,即Response Handler
。
总结上面的流程,我要做的是为每个阶段创建不同的路由,并以流程定义的方式触发或执行。
amazon-s3 - Camel AWS-S3 - 并非所有字节都从 S3ObjectInputStream 中读取,因此中止 HTTP 连接
我正在使用 camel-aws 将文件轮询到远程 S3 存储桶以检查它是否已到达。我对文件的内容不感兴趣。
我已将 includeBody 设置为 false 以不读取文件的内容,但是我收到以下警告:
amazon-s3 - Camel S3:在调度程序关闭的情况下列出 S3 存储桶文件
我正在遵循 Camel 路线,它试图从 S3 存储桶中读取文件列表:
然而,这条路线被每分钟运行的外部调度程序调用。看起来 Camel-S3 组件的默认行为是使用调度程序运行,但这会导致相同的文件被一次又一次地处理。
我尝试使用 startScheduler=false 关闭 Camel-S3 调度程序,但是当外部调度程序启动并获取“$ {header.CamelAwsS3Key}”的空值时,这不会执行“aws-s3”部分。
是否可以在没有内部调度程序的情况下运行此组件?
正在使用的骆驼版本 - 2.22.0
用于 aws 的依赖项:
apache-camel - 使用骆驼从 S3 存储桶中读取文件
我是骆驼的新手,需要一些指导。我需要从 S3 存储桶中读取一些文件。结构是这样的。
当一个特定的excel文件被放入incoming/xls文件夹(比如file1.xls)时,我需要提取所有文件,进行一些处理并将它们放入具有相同目录结构的已处理文件夹中。
我需要为此使用哪些组件?我尝试阅读文档,但有点难以弄清楚我需要哪些组件。我知道我将使用 camel-aws-s3 插件,但那里没有很多示例。
amazon-web-services - 在 AWS 中托管 Apache Camel 的最佳方式是什么?
当我们将工作负载转移到 AWS 时,我正在寻找一种广泛使用并具有适当连接器的 ETL 工具 - Apache Camel 似乎符合要求。但是,我很难找到有关如何在 AWS 中部署 Camel 的信息 - 显而易见的是在 EC2 实例上,但我们希望避免虚拟机所需的设置和维护。我没有看到有人将它作为托管服务提供,所以我想探索的选项是将它作为 ECS 中的容器运行,因为我们将运行许多其他容器。
容器似乎不是Apache Camel 网站上的安装选项- 也许它对于旨在连接到其他所有东西的工具来说太有限了?
在容器中运行 Camel 是否可以接受且实用,我在哪里可以找到有关它的更多信息?
amazon-web-services - 如何在骆驼的休息组件中执行from语句?
我为此使用 apache camel。我有一个 http 服务器。当我对 url 执行 get 请求时,它应该从 aws s3 中的存储桶中获取文件,然后在我的本地目录中创建一个文件。
我为此编写了上面的代码,但看起来它忽略了“from”语句并直接执行“to”语句,因此在我的 tmp 目录中创建了一个空文件。还有其他方法可以做到这一点吗?