从 Apache Nifi 运行 MarkLogic Data Hub 5 流答案

【问题标题】：Run a MarkLogic Data Hub 5 Flow from Apache Nifi从 Apache Nifi 运行 MarkLogic Data Hub 5 流
【发布时间】：2020-03-10 16:25:14
【问题描述】：

我成功使用 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 文档已经过时了？

【问题讨论】：

标签： marklogic apache-nifi marklogic-dhf

【解决方案1】：

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

【讨论】：