如何解析pyspark的DataStreamReader中的json字符串列并创建数据帧

from pyspark.sql import SparkSession
from pyspark.sql.functions import from_json
from pyspark.sql.types import StructType, StructField, StringType

spark = SparkSession.builder.appName("JsonParsing").getOrCreate()

json_schema = StructType([
    StructField("name", StringType(), True),
    StructField("age", StringType(), True),
    StructField("city", StringType(), True)
])

df = spark.readStream.format("json").option("multiline", "true").load("path/to/json/files")
parsed_df = df.select(from_json(df.json_column, json_schema).alias("parsed_data")).select("parsed_data.*")

query = parsed_df.writeStream.outputMode("append").format("console").start()
query.awaitTermination()