Запустите поток MarkLogic Data Hub 5 из Apache Nifi

Мне удалось использовать процессор PutMarkLogic в Nifi для вставки документов JSON в MarkLogic. Это создает простые документы JSON. Как добавить конверт концентратора данных во время приема? Как я могу запустить поток концентратора данных 5 во время приема?

Согласно документации MarkLogic Nifi на странице https://marklogic.github.io/nifi/run-data-hub-input-flow это можно сделать в процессоре PutMarkLogic с помощью свойства "Server transform" = "ml: sjsInputFlow" и настраиваемых свойств trans: flow-name и trans: entity -имя. Но это приводит к ошибке «Недопустимое принуждение» в MarkLogic:

2020-03-10 17:09:44.967 Notice: XDMP-AS: $src as node() -- Invalid coercion: null as node()
2020-03-10 17:09:44.967 Notice:+in /data-hub/4/impl/flow-lib.sjs, at 56:16, in getFlow() [javascript]
2020-03-10 17:09:44.967 Notice:+in /marklogic.rest.transform/mlSjsInputFlow/assets/transform.sjs, at 25:21, in transform() [javascript]
...

В stacktrace упоминается концентратор данных 4. Так может быть документация MarkLogic Nifi устарела?


person Andreas H    schedule 10.03.2020    source источник


Ответы (1)


Это для потока DHF 4. Используйте «mlRunIngest» в качестве имени преобразования и «trans: flow-name», чтобы указать имя потока, и «trans: step», чтобы указать номер шага.

person rjrudin    schedule 11.03.2020