如何以逗号分隔的形式显示spark streaming作业的数据帧输出？

from pyspark.sql import SparkSession

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

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

# 创建DStream，假设输入的数据流为textFileStream
lines = ssc.textFileStream("input_directory")

# 处理每个微批次的数据
lines.foreachRDD(lambda rdd: 
    if not rdd.isEmpty():
        # 将RDD转换为DataFrame
        df = spark.read.json(rdd)

        # 将DataFrame输出为逗号分隔的形式
        output = df.toPandas().to_csv(sep=',', index=False)

        # 打印输出
        print(output)
)

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