问题标签 [camel-sql]

我有一台物理服务器，其中运行了两个 Apache Camel 实例。两者都包含相同的集成工件。任务是将来自服务器文件系统的文件与由 cron 作业触发的 Apache Camel 文件组件集成。文件处理应该只发生一次。因此，我将幂等模式与同一台服务器上的 Jdbc 存储库一起使用。

一般来说，它工作正常。但有时，在少数情况下，两个实例都运行并读取文件，因此文件被处理两次。在 JDBC 数据库中，密钥也被插入了两次（甚至创建的时间戳也几乎相同；它在毫秒的第三位上有所不同）。

这就是我使用文件使用者的方式：

有谁知道我必须要文件只准备一次吗？

问候，伊恩

我是 stackoverflow 和 Apache Camel 的新手。我试着写一个可以理解的描述我的问题。

我的目标是从由父表中的 1 个条目和子表中的几行组成的数据库（mysql）中读取分层数据，并将这些数据转换为 pojo。子目标：不编写太多自定义代码并使用蓝图 xml。

由于我找不到适合这个问题的 EIP，所以我在这里列出了我迄今为止的方法：

1.通过连接查询选择数据

select * from parentTable join childTable on childTable.parentId=parentTable.id

这意味着编写一个自定义处理器将结果转换为 pojo，因为每次父属性都会为每个结果行获取选择结果。由于我试图避免编写自定义处理器，因此我尝试了以下方法：

2. 选择查询返回具有正确结构的 JSON 以转换为 pojo

在 mysql shell 上执行查询返回预期的 JSON：

在骆驼内部运行查询，我遇到了一个问题，我找不到解释或解决方案。

主体在查询执行后具有 JSON，但它被初始查询的片段包围：

问题：

1. 是否有现有的 EIP 可以解决我的问题？
2. 为什么在我的 2. 方法中没有正确的 JSON？

提前致谢

我有两个问题。

1. 第一个问题：我使用camel sql和camel csv来导出csv中的数据库。

我想显示列名，但是当我使用骆驼 2.16.5 版本时，骆驼 csv 的选项对我不起作用。

所有这些测试都没有奏效......

你能帮我解决这个问题吗？我怎样才能让它工作？

2. 第二个问题：由于骆驼 csv 选项不起作用，我想从 camel-csv-2.16.5.jar 调试 CsvDataFormat.class 但我得到了'Source not found The JAR file C:\Utilisateurs\.m2\repository\org\apache\camel\camel-csv-2.16.5.jar has no source attachment'。

我通过单击“附加源”手动附加了源，但我仍然看不到正确的源类。我尝试了网络中已经提到的所有解决方案，但没有奏效。

你有什么建议吗？

提前致谢

下面是我的代码：

直到上面的代码，一切正常，所有需要的数据都在文件中。当我尝试将文件移动到其他位置时，移动的文件仅包含来自上述数据提取查询的数据。以前的数据不在文件中。这里发生了什么？如何移动添加了所有数据的文件？

移动文件的代码：

如果我不移动文件，我拥有文件中的所有数据

我正在通过骆驼执行 mssql 查询，由于某种原因，我收到以下错误：

下面给出了我在代码中使用的查询，它在 mssql 服务器中运行良好，但不是通过骆驼代码，我使用的是骆驼 sql 组件。

SELECT * INTO #TEMP_TABLE FROM (SELECT NAME FROM TABLE_1)temp

我试图在 mssql 查询中实现临时表。这里#TEMP_TABLE 是临时表。在通过骆驼代码执行期间，骆驼将“#”作为一些不同的运算符，并且不提供临时表功能。

我对 Apache Camel 完全陌生，我很难阅读他们的文档。这是我的简化路线。

简而言之，我想读取 csv 并在 SQL 表中插入所有有效行。在我添加 .filter 以删除包含无效值的行之前，一切正常。不知道我做错了什么...

以下是处理/过滤方法

另外，也许 Camel pro 的某个地方有一个 Slack 频道可以帮助我？欢迎任何提示。

我正在尝试实现一个简单的流式传输管道：

1. 从远程 REST 端点获取用户列表，将列表拆分为单独的消息

2. 对于每个用户，我必须使用 SQL 参数表（部门）中的信息来丰富它，例如：

初始消息（用户 1）

部门

丰富的用户 1

路线背景：

我需要获取整个部门表才能丰富用户信息，但我想避免对每条消息都这样做。

有没有办法存储 sql 查询的内容并在丰富阶段重用它？

我想从 Azure SQL DB 表中读取 5+ 百万个事件并对 Cassandra 执行 BULK INSERT。该表有 2 列。我看到可用于从 Azure SQL DB 读取的 SQL 组件。https://camel.apache.org/components/3.7.x/sql-component.html

问题：从 Azure SQL DB 消费

1. 考虑到 5M 条记录，有没有更好的方法来读取所有行并存储在地图中？
2. 是否有可能批量阅读消息？

Cassandra 有一个可用的 cql 组件 https://camel.apache.org/components/3.7.x/cql-component.html

问题：生产到 Cassandra

1. 我们可以分批插入吗？

我可以在这个用例中使用骆驼吗？

当 Camel route toF("sql:insert into ...") 由于数据库连接问题而失败时，会引发哪个异常？

我试图捕捉，onException(CannotCreateTransactionException.class, ConnectionException.class) 但它没有捕捉到。如果我能捕捉到它，我想做最多 3 次重新交付并调用其他过程，如下所示

谢谢，

我使用 sql 端点从骆驼运行查询。但是，当我再次调用 CamelSqlRowCount 时，它并没有改变：

输出：2021-12-01 14:20:02.880 INFO OLD_AUDIT_DATA 1 - ROW_COUNT 1
2021-12-01 14:20:02.944 INFO OLD_AUDIT_DATA - ROW_COUNT 1

当我切换语句时：

输出：2021-12-01 14:22:25.021 INFO OLD_AUDIT_DATA - ROW_COUNT 0
2021-12-01 14:22:25.076 INFO OLD_AUDIT_DATA 1 - ROW_COUNT 0

如何重置标题？

提前致谢

巴特