管道中的 MarkLogic CPF- 条件模块

Question

MarkLogic 版本：9.0-6.2

我们数据库中的所有文档都是 JSON，我们使用 Javascript 来操作数据。我正在尝试创建一个管道，用于识别何时更新 JSON 文档中的 Phone 数字（使用条件模块），然后运行操作模块。到目前为止，我得到了以下代码。

{
  "pipeline-name": "CPF async Test",
  "pipeline-description": "CPF Test",
  "success-action": {
      "module": "/MarkLogic/cpf/actions/success-action.xqy"
  },
  "failure-action": {
      "module": "/marklogic/cpf/actions/failure-action.xqy"
  },
  "status-transition": [
    {
      "annotation": "",
      "status": "updated",
      "on-success": "http://marklogic.com/states/done",
      "on-failure": "http://marklogic.com/states/error",
      "execute": [
         {
           "condition": {
           "module": ???
           },
           "action": {
           "module": "sleepTest.sjs"
          }
        }
     ]
   }
 ]
}

当我尝试使用管理控制台（过滤器为 filename.json）将此 JSON 作为管道加载时，我收到一条消息 "Invalid input: No readable XML files found:"

管道应该总是XML吗？
我能够编写（在 JavaScript 中）并成功执行操作模块。我在 XML 管道中对其进行了测试。我也可以在 JavaScript 中编写条件模块吗？
我不确定是否有 MarkLogic 提供的内置条件模块来识别对属性的更改（通过将属性作为参数传递给条件模块）。如果是，能否请您指出文档？如果我必须创建自定义条件模块，如何将新旧 phone 号码传递给模块？条件模块的外观如何，最好是 JavaScript?

我在 CPF 上找到的大部分文档都是 XML/XQuery。感谢任何指向 JSON/JavaScript CPF 文档的指针。

提前致谢！

Answer 1

管道可以在 XML 或 JSON - 这个 ml-gradle 示例项目中有一些例子 - https://github.com/marklogic-community/ml-gradle/tree/master/examples/cpf-project/src/main/ml-config/cpf/pipelines .

我认为条件模块可以是 JS 或 XQuery。

至于检测更改 - CPF 通过 post-commit 触发器运行，因此在条件或操作模块运行时文档已经更新。因此，您需要将旧值存储在文档的某个位置。这与 MarkLogic 无关，但这里的一种方法是使用 JSON 补丁规范，以便客户端通过补丁指定更改。您可以将补丁保存为单独的文档（或作为 phone 编号文档的一部分）并更新 phone 编号文档。 condition/action 模块然后可以查看最新的补丁以查看进行了哪些更改。

Answer 2

指出的例子在XQuery中只有CPF条件模块。下面是 XQuery 和服务器端 JavaScript 版本的比较（省略日志记录）：

样本-condition.xqy link to the original on GitHub

xquery version "1.0-ml";
declare namespace cpf = "http://marklogic.com/cpf";
declare variable $cpf:document-uri as xs:string external;
(: your custom condition logic :)
return true()  (: or false() :)

样本-condition.sjs

'use strict'
const cpf = require('/MarkLogic/cpf/cpf')
// your custom condition logic
fn.true()  // or fn.false()

文档：https://docs.marklogic.com/js/cpf

管道中的 MarkLogic CPF- 条件模块

MarkLogic CPF- condition module in pipeline

marklogic

marklogic-9

marklogic-dhf