如何在 Apache Nifi 中实现 ExtractCCDAAttributes 处理器?

How to implement ExtractCCDAAttributes processor in Apache Nifi?

我正在提取一些医疗保健数据。最初使用 XML 文件格式的 CCDA 开始。我如何配置 ExtractCCDAAttributes 以使用其值提取属性?

您可以参考这个演示使用 ExtractCCDAAttributes 处理器的最小流程。

1) 获取 CDA 文档(处理器类型:GetFile

这将创建一个包含文档内容的 FlowFile。使用的示例数据文件 (XML) 可用 here

2) ExtractCCDAAttributes(处理器类型:ExtractCCDAAttributes

此处理器有一个 属性 (Skip Validation) 来指示是否验证 CDA 消息值。我们接受 true 的默认值。处理器将单个属性输出为 FlowFile 属性。

3) 成功(处理器类型:LogAttribute

这是在 ExtractCCDAAttributes 处理器成功时记录属性。

4) 失败(处理器类型:LogAttribute

这是在 ExtractCCDAAttributes 处理器发生故障时记录属性。

验证:

处理 sample file 时,Success 处理器记录的(许多)属性中的两个是:

Key: 'vitalSignsSection.organizer_01.observations_02.code.displayName'
    Value: 'Intravascular Systolic'

Key: 'vitalSignsSection.organizer_02.observations_03.code.displayName'
    Value: 'Intravascular Systolic'

在示例文件中,出现这些的两个地方是第 3592 行和第 3700 行: