我正在寻找一个Python代码实现来将Pandas Dataframe转换成下面提到的格式的json
文件。你知道吗
输入Python数据帧如下(input_data - dataframe name
)
stateacttraf |stateno | statename | actno | actname | traffic | reward | id | message
stateacttraf | 1 | S1 | 1 | A1 | 22 | 3 | 234569 | stateactsplit
stateacttraf | 1 | S1 | 2 | A2 | 30 | 4 | 234569 | stateactsplit
stateacttraf | 1 | S1 | 3 | A3 | 48 | 2.3 | 234569 | stateactsplit
stateacttraf | 2 | S2 | 1 | A1 | 13 | 4.1 | 234569 | stateactsplit
stateacttraf | 2 | S2 | 2 | A2 | 27 | 8.2 | 234569 | stateactsplit
stateacttraf | 2 | S2 | 3 | A3 | 60 | 5.6 | 234569 | stateactsplit
Dataframe应该像以下json格式的示例,需要在kafka中发布:
{
"stateacttraf": "1, S1, 1 , A1 , 24.5,3 \n
1, S1, 2 , A2 , 25.5,4 \n
1, S1, 3 , A3 , 20,2.3 \n
2, S2, 1 , A1 , 10,4.1 \n
2, S2, 2 , A2 , 10,8.2 \n
2, S2, 2 , A2 , 10,5.6 \n",
"message": "stateactsplit",
"id": 234569
}
在示例输出中,\n
只是表示这些(1, S1, 2 , A2 , 25.5,4)
的每一行都应该打印在新行中。你知道吗
尝试使用input_data.to_json(orient='index', lines=True)
,但每行中的每个值的列名都会重复。你知道吗
这不是一个好的JSON格式,但是我编写了适合您的代码:
请尝试以下代码:
以下是JSON格式的数据:
提示如果你不想发疯,我建议你换成标准的json格式
相关问题 更多 >
编程相关推荐