如何在pyspark上读取以avro schema对象作为头的CSV？

from pyspark.sql import SparkSession

# 创建SparkSession对象
spark = SparkSession.builder.appName("Read CSV with Avro Schema").getOrCreate()

# 定义avro schema对象
avro_schema = {
    "type": "record",
    "name": "csv_data",
    "fields": [
        {"name": "col1", "type": "string"},
        {"name": "col2", "type": "string"},
        {"name": "col3", "type": "string"}
    ]
}

# 读取以avro schema对象作为头的CSV文件
df = spark.read.format("csv") \
    .option("header", True) \
    .option("inferSchema", False) \
    .option("avroSchema", str(avro_schema)) \
    .load("path/to/csv/file.csv")

# 打印DataFrame内容
df.show()

# 停止SparkSession
spark.stop()