mysql - Mongo 到 MySQL 在 Pentaho PDI 中的转换

Question

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

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

我正在使用 Pentaho Data Integration Community Edition 4.4.0

Answer 1

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

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