Я пытаюсь создать вложенный json для блоков данных.
Это код, который я использовал:
data = df.groupby('plant', 'at').agg(
F.collect_list(
F.struct(F.col("product"),F.col("quantity"))
).alias('products'))
Мне нужно получить
{"plant":"plant_x","at":"2019-06-12T13:54:29.947Z","products":[{"product":"product1","quantity":39}, {""product"":""product2"",""quantity"":2} ]
но вместо этого я получаю что-то другое с "/" и странным [] {}, и удваивается ""
plant_x,2019-06-13T13:23:12.539+0000,"[{""product"":""product1"",""quantity"":39},{""product"":""product2"",""quantity"":2} ]"
Может кто-нибудь помочь, пожалуйста?