Запустите MarkLogi c Data Hub 5 Поток от Apache Nifi - PullRequest
Новая
       27

Запустите MarkLogi c Data Hub 5 Поток от Apache Nifi

1 голос
/ 10 марта 2020

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

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

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]
...

В стека трассировки данных упоминается хаб 4. Так что, может быть, документация MarkLogi c Nifi устарела?

1 Ответ

2 голосов
/ 11 марта 2020

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

...