从Apache Nifi运行MarkLogic Data Hub 5流

Question

我成功地在Nifi中使用PutMarkLogic处理器将JSON文档插入MarkLogic。这将创建普通的JSON文档。提取期间如何添加数据中心信封？提取期间如何启动数据中心5流？

根据https://marklogic.github.io/nifi/run-data-hub-input-flow处的MarkLogic Nifi文档，这可以在PutMarkLogic处理器中通过属性“ Server transform” =“ ml：sjsInputFlow”和自定义属性trans：flow-name和trans：entity-name来完成。但这会在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]
...

在堆栈跟踪数据集线器4中。那么，也许MarkLogic Nifi文档已经过时了？

Answer 1

这是DHF 4流程。使用“ mlRunIngest”作为转换名称，并使用“ trans：flow-name”指定流名称，并使用“ trans：step”指定步骤号。