PySpark -插入行或使用json响应创建新的数据帧

from pyspark.sql import SparkSession
from pyspark.sql.types import StructType, StructField, StringType, IntegerType

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

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

df = spark.createDataFrame([], schema)

# 插入行
df = df.union(spark.createDataFrame([("John", 25, "New York")], schema))

# 使用JSON响应创建新的数据帧
json_response = '{"name":"Alice", "age":30, "city":"London"}'
df = df.union(spark.read.json(spark.sparkContext.parallelize([json_response]), schema=schema))