Marklogic 提交帧/返回序列保证

Question

我有一个简单的 1 节点 Marklogic 服务器，我需要每天清除文档。

下面的测试查询选择文档然后返回我想要执行以下操作的序列：

1. 输出要解压的文件名
2. 确保#1中文件的目录路径存在
3. 将文档的压缩版本保存到 #1 中的文件中。
4. 删除文档

这个结构安全吗？它为要删除的每个文档返回一个序列。返回序列中的最后一项删除文档。如果前面的任何步骤失败，文档是否仍会被删除？我应该相信引擎按给定的顺序执行返回序列吗？

xquery version "1.0-ml";
declare namespace html = "http://www.w3.org/1999/xhtml";
let $dateLimitAll := current-dateTime() -xs:dayTimeDuration("P1460D")
let $dateLimitSome := current-dateTime() -xs:dayTimeDuration("P730D")
for $adoc in doc()[1 to 5]
 let $docDate := $adoc/Unit/created
 let $uri := document-uri($adoc)
 let $path:=  fn:concat("d:/purge/" , $adoc/Unit/xmldatastore/state/data(), "/", fn:year-from-dateTime($docDate), "/", fn:month-from-dateTime($docDate))
 let $filename :=  fn:concat($path, "/", $uri, ".zip")
where ( ($docDate < $dateLimitAll) or (($docDate < $dateLimitSome) and ($adoc/Unit/xmldatastore/state != "FIRMED") and ($adoc/Unit/xmldatastore/state != "SHIPPED")))
return ( $filename, xdmp:filesystem-directory-create($path, map:new(map:entry("createParents", fn:true()))), xdmp:save($filename, xdmp:zip-create(<parts xmlns="xdmp:zip"><part>{$uri}</part></parts>, doc($uri))), xdmp:document-delete($uri) )

附言请忽略 [1 到 5] 文档限制。添加用于测试。

Answer 1

如果前面的任何步骤都失败了，文档还会被删除吗？

如果在该模块的执行过程中出现错误，事务将回滚并且从数据库中删除将被撤消。

但是，写入文件系统的目录和 zip 文件将保留，不会被删除。如果事务回滚，xdmp:filesystem-directory-create() 和 xdmp:save() 函数不会回滚或撤消。

我应该相信引擎按照给定的顺序执行返回序列吗？

鉴于上面的陈述，不确定它是否重要。

这个结构安全吗？

目前尚不清楚您可能要处理多少文件。您可能会发现使用cts:search 和一些索引来定位候选文档的过滤器更好/更快。此外，即使您可以选择更快处理的文档集，但如果有很多文档，您仍然可能超过执行时间限制。

另一种方法可能是拆分工作。选择符合条件的文档的 URI，然后对负责保存 zip 文件和从数据库中删除文档的每个文档执行单独的查询。这可能会更快，因为您可以并行处理多个文档，避免超时风险，并且在发生异常时，允许某些项目失败而不会导致整个集合失败和回滚。

CoRB 等工具正是为此类批处理工作而构建的。