Mongo to MySQL конвертирует в Pentaho PDI

Question

Я создал на трансформации в Pentaho PDI, который переводит из моих монгольских коллекций в MySQL. Для этого я использовал вывод ввода и вывода Mongodb. В выводе таблицы я выбрал truncate table true. Теперь моя проблема приведена ниже:

1. Я хочу запустить свою трансформацию каждые 5 минут. потому что моя коллекция обновляется каждые 5 мин.
2. Я хочу вставить только новые добавленные документы в таблицу MySQL, для проверки новых добавленных документов. Я установил ключ статуса и был установлен в 1, и после обработки я обновил его до 0.
3. Иногда мои коллекции содержали вложенные данные. Как вложенные данные попадают в MySQL

Я использованияКонтактная Pentaho Интеграция данных Community Edition, 4.4.0

Answer 1

Во-первых, я настоятельно рекомендую вам использовать версию Pentaho Big Data: 1.3.3.1 потому retreiving от Вход MongoDB чрезвычайно прост.

Вместо проверки опции «обрезать таблицу» в выводе таблицы, создайте шаг «Execute Sql» перед вводом MongoDB с инструкцией delete (удалите все модифицированные элементы, например) и в ваш MongoDB-вход в поле ' Выражение запроса (JSON) просто заставляет вас искать документы с ключом состояния = 1