有没有办法修改这段代码，让spark streaming从json中读取数据？

from pyspark.streaming import StreamingContext
from pyspark.sql import SparkSession
import json

# 创建SparkSession
spark = SparkSession.builder.appName("JSONStreaming").getOrCreate()

# 创建StreamingContext
ssc = StreamingContext(spark.sparkContext, 1)

# 从TCP Socket接收数据流
lines = ssc.socketTextStream("localhost", 9999)

# 将每行数据解析为JSON对象
json_data = lines.map(lambda x: json.loads(x))

# 将JSON对象转换为DataFrame
df = spark.read.json(json_data)

# 处理DataFrame中的数据
df.show()

# 启动StreamingContext
ssc.start()
ssc.awaitTermination()