link管理
链接快照平台
- 输入网页链接，自动生成快照
- 标签化管理网页链接
相关文章推荐
|
热心肠的凉茶 · ECharts-图表里面加入线绘制表格-Ec ...· 1 月前 · |
|
|
讲道义的小熊猫 · C# ElementAt() - CSDN文库· 9 月前 · |
|
|
腼腆的茶叶 · 校招黑名单和955公司名单 - 知乎· 1 年前 · |
|
|
潇洒的书签 · Search Results - ...· 1 年前 · |
|
|
很酷的橡皮擦 · python中的subprocess.Pop ...· 1 年前 · |
NiFi通过JsonPathReader或JsonTreeReader将JSON转换为CSV
问
NiFi通过JsonPathReader或JsonTreeReader将JSON转换为CSV
EN
EN
Stack Overflow用户
提问于
2020-08-19 14:30:56
回答 1
查看 367
关注 0
票数 0
我正在尝试将JSON文件转换为CSV，但我似乎没有这样做的运气。我的JSON看起来是这样的：{{
代码语言：
javascript
复制
{"meta": {
"contentType": "Response"
"content": {
"data": {
"_type": "ObjectList",
"erpDataObjects": [
"meta": {
"lastModified": "2020-08-10T08:37:21.000+0000",
"head": {
"fields": {
"number": {
"value": "1",
"id": {
"value": "10000"
"meta": {
"lastModified": "2020-08-10T08:37:21.000+0000",
"head": {
"fields": {
"number": {
"value": "2",
"id": {
"value": "10001"
"meta": {
"lastModified": "2020-08-10T08:37:21.000+0000",
"head": {
.. much more data我基本上希望我的csv看起来像这样：
代码语言：
javascript
复制
number,id
1,10000
2,10001我的流程是这样的：
GetFile ->设置输出文件名-> ConvertRecord -> UpdateAttribute -> PutFile 。
ConvertRecord使用JsonTreeReader和CSVRecordSetWriter JsonTreeReader CsvRecordSetWriter 。他们都调用了一个AvroSchemaRegistry，它看起来如下所示： AvroSchemaRegistry ，AvroSchema本身如下所示：
代码语言：
javascript
复制
{
"type": "record",
"name": "head",
"fields":
{"name": "number", "type": ["string"]},
{"name": "id", "type": ["string"]},
}但我只得到了这个输出：
代码语言：
javascript
复制
number,id
,这是有意义的，因为我并没有特别指出这些值的位置。我以前使用过JsonPathReader，但它看起来只是这样： JsonPathReader ，显然只给了我一张唱片。我不太确定如何配置这两种方法中的任何一种来输出我想要的结果。我会非常感谢你的帮助！
EN
回答 1
Stack Overflow用户
发布于 2020-08-19 21:10:35
使用ConvertRecord用于JSON，-> CSV主要用于“平面”->文件，其中对象中的每个字段都成为传出->文件中的一列。对于嵌套/复杂结构，请考虑JoltConvertRecord，它允许您执行更复杂的转换。您的示例似乎不像-原样是有效的JSON，但是假设您的输入是这样的：
代码语言：
javascript
复制
{
"meta": {
"contentType": "Response"
"content": {
"data": {
"_type": "ObjectList",
"erpDataObjects": [
"meta": {
"lastModified": "2020-08-10T08:37:21.000+0000"
"head": {
"fields": {
"number": {
"value": "1"
"id": {
"value": "10000"
"meta": {
"lastModified": "2020-08-10T08:37:21.000+0000"
"head": {
"fields": {
"number": {
"value": "2"
"id": {
"value": "10001"
}下面的抖动规范应该为您提供输出所需的内容：
代码语言：
javascript
复制
[
"operation": "shift",
"spec": {
"content": {
"data": {
"erpDataObjects": {
"*": {
"head": {
"fields": {
"number": {
"value": "[&4].number"
"id": {
"value": "[&4].id"