除非PutMarklogic处理器

Question

我打算使用Nifi marklogic处理器从我的s3存储桶中提取文档。

• 使用MLCP下面是putMarklogic吗？
• 可以采用所有MLCP选项，例如：aggregate_record_namespace或transform_module或transform_namespace或transform_param
• 如果没有，我有什么选择，是编写自定义处理器，使用MCLP，因为我喜欢MLCP提供的灵活性:)

如你所见，我打算调用我的DHF输入流..所以看完代码之后我想我可以设置transform:ml:inputFlow和其他变换参数前缀为trans: ..这是正确的吗？

我怎么做mlcp aggregates和aggregate_record_element和aggregate_record_namespace ..因为我正在加载带有多个xml文件的.xml.gz文件..或者我唯一的选择是将它们分解为单个文件

Answer 1

我解决了这个问题，我写了一个调用ContentPump.runCommand的自定义处理器。只是fyi，如果有人感兴趣，我不得不排除log4j并添加log4j-over-slf4j所以mclp可以写进度记录到nifi-app.log。