MarkLogic DHF 5中基于词典（Lexicon）值实现分步执行的方案咨询

我刚好处理过类似的DHF5迁移问题，针对你遇到的情况，这里有几个可行的解决方案，帮你替代DHF4中自定义Collector的功能：

方案1：创建自定义Collector步骤 #

DHF5虽然移除了旧版的Collector自定义选项，但支持通过添加自定义Collector类型的步骤来生成自定义输入序列，完美适配遍历词典值的场景：

1. 在Flow编辑器中添加一个新步骤，将步骤类型设置为Collector
2. 在步骤的代码编辑器中，编写逻辑获取词典值并返回序列：

function collect(context, params) {
    // 替换为你的实际词典查询，比如针对某个属性的词典
    const dictionaryValues = cts.values(cts.jsonPropertyReference("targetProperty"));
    // 将值序列转为数组返回，DHF会自动将每个值作为后续步骤的单独输入项
    return dictionaryValues.toArray();
}

3. 后续的Mapper/自定义步骤就可以直接接收每个词典值作为输入参数，执行你需要的处理逻辑。

方案2：在sourceQuery中包装词典值 #

如果想继续使用默认的Collector流程，你需要将cts.values返回的原始值包装成DHF后续步骤可以识别的对象（默认步骤通常期望处理文档或结构化对象）：
在Flow的sourceQuery中使用以下代码（以JavaScript为例）：

cts.values(cts.jsonPropertyReference("targetProperty"))
  .map(value => ({ dictionaryValue: value }))

这样sourceQuery返回的是包含词典值的对象序列，后续步骤可以通过读取dictionaryValue字段来获取目标值进行处理。

为什么直接用cts.values会失败？ #

DHF5的默认后续步骤（比如Mapper）默认期望处理的是文档节点或URI，而cts.values返回的是原始的字符串/数值类型，步骤无法识别这种输入，因此会出现无提示失败。查看MarkLogic安装目录/logs/dhf/dhf.log可以找到具体的错误日志，帮助你定位问题。

额外调试建议 #

如果还是遇到问题，建议：

• 先在Query Console中测试你的cts.values查询，确保能返回预期结果
• 自定义步骤中添加日志输出，比如fn.log("当前处理值：" + value)，便于跟踪流程执行情况

内容的提问来源于stack exchange，提问作者Alexandru Mortan