我有下面的pysppark行类型数据:
indv_msg = [Row(cbm_json_output=Row(country_code='USA', date='06-10-2023', date_epoch='1696550400', id='USA-001535-1696550400', interfaceVersion='1.0.0', opmode_car_door=Row(health_category='GREEN', msg_id='1', num_yellow_preds_in_last_14_days=0, reason=None, reasonDetail=None), opmode_landing_door=Row(health_category='GREEN', msg_id='1', reason=None, reasonDetail=None), sensor=Row(component_type=None, health_category=None, landing_priority=None, msg_id='1', num_yellow_preds_in_last_14_days=None, reason=None, reasonDetail=None), unit_id='001535'))
在try 转换为json字符串时,它正在消除赋值字段,如"COUNTRY_CODE"、"DATE"、...
user_encode_data = json.dumps(indv_msg, indent=2)
结果: 消息源(_M)
[
[
"USA",
"06-10-2023",
"1696550400",
"USA-001535-1696550400",
"1.0.0",
[
"GREEN",
"1",
0,
null,
null
],
[
"GREEN",
"1",
null,
null
]
]
预期结果: 消息源(_M)
[
[
"country_code" : "USA",
"date" : "06-10-2023",
"date_epoch": 1696550400",
....
....
]
]