使用 marklogic nifi 连接器，我可以将文档从 ML DB 带到带有 Nifi 的磁盘文件夹中。关键在于 QueryMarkLogic Processor.
我需要设置一个工作流来持续监控 ML DB 内容数据库，以将任何“更改的”文档放入磁盘文件夹中。
怎么做？
我正在考虑使用“同步标志”集合来标记 ML 中已“更改”的文档。 （这意味着文档更改必须通过 ML 内部的自定义 XQuery 函数进行）。然后运行服务器转换脚本以清除 QueryMarkLogic 处理器中的该集合。这是为了确保它只会放置一次文件。
但是，如何使 QueryMarkLogic Processor 连续运行该查询？ 看来我将不得不停止查询处理器并重新启动以再次监视该“同步标志”集合。