目前kafka中的数据样例如下：
{
“ver”: “0.0.1”,
“pKey”: “CL000002”,
“sn”: “AK1407120700022”,
“ts”: 1695274554,
“type”: “rtg”,
“seq”: 0,
“inverter”: {
“pKey”: “CL000002”,
“sn”: “AK1407120700022”,
“runMode”: 2,
“pGrid”: [
3179,
1034,
1091,
1054
],
“uGrid”: [
3848,
2238,
2248,
2180
],
“cGrid”: [
482,
471,
488,
489
],
“pUps”: [
3106,
1049,
1081,
976
],
“uUps”: [
3886,
2260,
2291,
2181
],
“cUps”: [
462,
465,
473,
448
],
“temp”: 42,
“invErr1”: 0,
“invErr2”: 0,
“invAlarm”: 0,
“emsErr”: 0,
“pPvTotal”: 0,
“pLoad”: 0,
“pSelfuse”: 0,
“pChg”: 0,
“pDischg”: 3061
},
“meter”: [
{
“pKey”: “WL000002”,
“sn”: “s1”,
“pAct”: [
-411,
259,
-53,
-618
],
“u”: [
3931,
2291,
2315,
2204
],
“c”: [
0,
64,
75,
82
],
“freq”: 5003,
“pImport”: 1618,
“pExport”: 366,
“err”: 0
}
],
“battery”: {
“pKey”: “WL000003”,
“sn”: “0B0LBL1K104011D8P1000001”,
“staSts”: 6,
“relaySts”: [
1,
1,
1,
1,
0
],
“soc”: 38,
“bAlarm1”: 0,
“bAlarm2”: 0,
“cAlarm1”: 0,
“chgCurrLimit”: 2490,
“dischgCurrLimit”: 2490,
“uTotHvs”: 4179,
“iHvs”: 85,
“socHvs”: 384,
“sohHvs”: 100
},
“photovoltaic”: [
{
“pKey”: “WL000004”,
“sn”: “”,
“pPv”: [
0,
0,
0
],
“uPv”: [
0,
0,
0
],
“cPv”: [
0,
1,
0
]
}
]
}