pyspark dataframe 转 json 逐行输出

 pd = df.toPandas()
 resjson = pd.to_json(orient='records')
 return  resjson