管道中的MarkLogic CPF-条件模块

Question

MarkLogic版本：9.0-6.2

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

{
  "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"
          }
        }
     ]
   }
 ]
}

1. 当我尝试使用管理控制台（使用filter作为filename.json）将此JSON加载为管道时，我收到一条消息“输入无效：找不到可读的XML文件：” 管道应该始终是XML吗？
2. 我能够（用JavaScript编写）并成功执行动作模块。我在XML管道中测试了它。我也可以在JavaScript中编写条件模块吗？
3. 我不确定MarkLogic是否提供内置条件模块来识别属性的更改（通过将属性作为参数传递给条件模块）。如果是，请您指出文档？如果我必须创建自定义条件模块，如何将新旧电话号码传递给模块？条件模块的外观如何，最好是在JavaScript中？

我在CPF上找到的大多数文档都是XML / XQuery。任何指向JSON / JavaScript CPF文档的指针都表示赞赏。

提前致谢！

Answer 1

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

sample-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

Answer 2

管道可以是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通过提交后触发器运行，因此在条件或操作模块运行时文档已经更新。因此，您需要将旧值存储在文档的某个位置。这与MarkLogic相关，但这里的一种方法是使用JSON补丁规范，以便客户端通过补丁指定更改。您可以将修补程序作为单独的文档（或作为电话号码文档的一部分）保留，并更新电话号码文档。然后，条件/操作模块可以查看最新的补丁以查看所做的更改。