Apache Nifi - 获取文件属性并通过自定义处理器构造 json
Apache Nifi - get the file attributes and construct the json through custom processor
我正在使用自定义处理器进行 csv 到 json 的转换,它将 csv 文件数据转换为 json 数组,其中包含 json 个数据对象。
我的要求是获取文件名、uuid、路径等文件属性,并从中构造一个 json。
问题:
如何获取文件的相关属性并构建 json 对象并将其附加到之前构建的相同 json。
刚刚使用 apache nifi 几天,所以现在使用自定义处理器来满足确切的要求。
我不知道为您的自定义处理器编写了哪些属性,但是有一组 core attributes that most/all flow files have, such as filename and uuid. If you are using GetFile or ListFile/FetchFile 可以读取到您的 CSV 文件中,您将拥有这些和许多其他可用属性(有关更多信息,请参阅文档)。
当您有一个设置了适当属性的流文件时,您可以使用 AttributesToJSON 处理器创建一个 JSON 包含指定属性的平面列表的对象,并且该对象可以根据 AttributesToJSON.
的 "Destination" 属性 的设置,替换流文件内容或成为自己的属性(命名为 'JSONAttributes')
我正在使用自定义处理器进行 csv 到 json 的转换,它将 csv 文件数据转换为 json 数组,其中包含 json 个数据对象。
我的要求是获取文件名、uuid、路径等文件属性,并从中构造一个 json。
问题:
如何获取文件的相关属性并构建 json 对象并将其附加到之前构建的相同 json。
刚刚使用 apache nifi 几天,所以现在使用自定义处理器来满足确切的要求。
我不知道为您的自定义处理器编写了哪些属性,但是有一组 core attributes that most/all flow files have, such as filename and uuid. If you are using GetFile or ListFile/FetchFile 可以读取到您的 CSV 文件中,您将拥有这些和许多其他可用属性(有关更多信息,请参阅文档)。
当您有一个设置了适当属性的流文件时,您可以使用 AttributesToJSON 处理器创建一个 JSON 包含指定属性的平面列表的对象,并且该对象可以根据 AttributesToJSON.
的 "Destination" 属性 的设置,替换流文件内容或成为自己的属性(命名为 'JSONAttributes')