小编meh*_*meh的帖子

在 NiFi 中将两个 JSON 流文件合并在一起

我想通过相同的指定属性合并两个包含 JSON 对象的流文件...

流程1:

attribute:    
xuuid = 123456

content:
{
"sname":"jack",
"id":"00001",
"state":"NY"
}
Run Code Online (Sandbox Code Playgroud)

流程2:

attribute:    
xuuid = 123456

content:
{
"country":"US",
"date":"1983"
}
Run Code Online (Sandbox Code Playgroud)

我希望在单个输出流中出现这种形式的数据:

期望流:

attribute:    
xuuid = 123456

content:
{
"sname":"jack",
"id":"00001",
"state":"NY",
"country":"US",
"date":"1983"
}
Run Code Online (Sandbox Code Playgroud)

我怎么玩这个?MergeContent 处理器还是 MergeRecord?我认为 mergeecord 可以处理它,但我对此感到困惑。

apache-nifi

5
推荐指数
2
解决办法
7054
查看次数

在python中将JSON字典转换为JSON数组

我有这样的 JSON 字典:

{'foo': 3, 'bar': 1}
Run Code Online (Sandbox Code Playgroud)

我希望它以 JSON 数组形式出现:

[ { "key": "foo", "value": 3 }, { "key": "bar", "value": 1 }] 
Run Code Online (Sandbox Code Playgroud)

我该怎么办?

python arrays json

5
推荐指数
1
解决办法
5074
查看次数

NiFi使用ConvertRecord将json转换为csv

我在apache nifi中有一个包含动态字段(最多11个字段)的json流,我想将其转换为csv文件.

样品json:

{  
   "field1":"some text",
   "field2":"some text",
   "field3":"some text",
   "field4":"some text",
   "field5":"some text",
   "field6":"some text",
   "field7":"some text"
}
Run Code Online (Sandbox Code Playgroud)

我不想使用replace或json评估; 我是怎么用ConvertRecord做的?使用这个处理器是如此奇怪和难以工作......

清楚地表达动态字段: 我总共有11个字段.一条记录可能包含7个字段,下一条记录可能包含11个字段,接下来的9个字段...

csv json apache-nifi

1
推荐指数
1
解决办法
2179
查看次数

标签 统计

apache-nifi ×2

json ×2

arrays ×1

csv ×1

python ×1