我是NiFi和Python的新手,我需要您的帮助才能将Flow File属性值传递给脚本。脚本正在将嵌套的json转换为csv。当我在本地运行脚本时,它可以工作。如何将FlowFile名称传递给src_json和tgt_csv?谢谢,import pandas as pdfrom pandas.io.json i
我是Nifi的新手,在我的例子中,我必须使用来自Kafka的JSON主题,并希望将其转换为CSV文件,其中我只需要选择一些标量和一些嵌套字段。我需要做以下事情: Consume topic - Done Include header in the CSV file
Merge into single fileproper filen
我正在将一个超过10层的嵌套JSON对象转换为C# .NET中的CSV文件。我一直在使用JavaScriptSerializer().Deserialize<ObjectA>(json)或XmlNode xml = (XmlDocument)JsonConvert.DeserializeXmlNode(json)来分解对象。有了这些对象,我可以进一步写入CSV文件。但是