我已经从字典列表中创建了一个pandas数据框架，并使用json\u normalize取消了一列的pivot。现在我必须将代码转换为使用pyspark而不是pandas。

df = pd.json_normalize(list_json,'Messages',['ID'])

ID, Active, Description, Priority
21122, true ,Test description1, 2
21233,true ,Test description1, 2
21233,true ,test2 , 3

在pyspark中，我想不出类似的函数。
我用下面的代码创建了一个Dataframe。但我不知道怎么把它拔出来。

df = spark.sparkContext.parallelize(list_json_messages_tea).map(lambda x: json.dumps(x))
df = spark.read.json(df)

ID, Messages
21122, [{"Active": "true", "Description": "Test description1", "Priority": "2"}]
21233, [{"Active": "true", "Description": "Test description1", "Priority": "2"}, {"Active": "true", "Description": "test2",  "Priority": "3"}]