mysql - 在 Pentaho PDI 中将 Mongo 转换为 MySQL

Question

我在 Pentaho PDI 中创建了从我的 Mongo 集合转移到 MySQL 的转换。为此，我使用了 Mongodb 输入和表输出。在表输出中，我选择了 truncate table true。现在我的问题如下：

1. 我想每 5 分钟运行一次转换。因为我的收藏每 5 分钟更新一次。
2. 我只想在 MySQL 表中插入新添加的文档，以检查新添加的文档。我设置状态键并将其设置为 1，处理后我将其更新为 0。
3. 有时我的集合包含嵌套数据。嵌套数据如何到达 MySQL

我正在使用 Pentaho 数据集成社区版 4.4.0

Answer 1

首先，我强烈建议您使用 Pentaho Big Data 版本：1.3.3.1，因为从 MongoDB Input 检索非常容易。

不要在表输出中检查选项“截断表”，而是在 MongoDB 输入之前创建一个“执行 Sql”步骤，使用删除语句（例如，删除所有修改的元素）并在 MongoDB 输入中的“查询表达式（JSON ) 只是把你想用 status key = 1 检索文档