我创建了一个实体并创建了输入和协调流程。我可以看到生成的 XQuery 文件。
现在我有一个要求,我需要对我的原始数据做一些(if-else),并根据我需要将一些数据推送到我的最终数据库的条件,并且一些数据将保留在 STAGING 本身中(那不应该去进入决赛)。
我对需要更改代码的文件(main.xqy、headers.xqy 等)感到困惑,所以如果我运行 Harmonize Flow,那么整个事情应该可以一次性完成。
我创建了一个实体并创建了输入和协调流程。我可以看到生成的 XQuery 文件。
现在我有一个要求,我需要对我的原始数据做一些(if-else),并根据我需要将一些数据推送到我的最终数据库的条件,并且一些数据将保留在 STAGING 本身中(那不应该去进入决赛)。
我对需要更改代码的文件(main.xqy、headers.xqy 等)感到困惑,所以如果我运行 Harmonize Flow,那么整个事情应该可以一次性完成。
MarkLogic 操作数据中心框架中的每个协调流插件都旨在进行定制。有五个插件,collector.xqy、content.xqy、header.xqy、triples.xqy 和 writer.xqy。最简单的协调如下:
以下是ODH Wiki中每个插件的摘要:
选择暂存数据库中要处理的文档的 ID。
将输入数据转换为规范化或规范格式以存储在最终文档中。您可以在此处添加自定义转换代码。
标题插件负责从内容中提取标题项。您可以在此处的标题部分添加元数据或扩充内容。
三元组插件负责从源内容中提取语义三元组。您可以控制信封文档中嵌入的三元组。
编写器插件负责将最终信封写入数据库。您可以使用此模块控制协调文档的输出权限、URI、集合等。