TypeError：“ DataFrameReader”对象不可调用

Question

我正在使用PySpark读取csv文件。下面是我的简单代码。

from pyspark.sql.session import SparkSession

def predict_metrics():
    session = SparkSession.builder.master('local').appName("PredictFacebookMetrics").getOrCreate()
    dataframe = session.read().format('com.databricks.spark.csv') \
        .option('header', True) \
        .option('delimiter', ';') \
        .option('inferSchema', True) \
        .load(r'D:\M\Facebook_metrics_data\dataset_Facebook.csv')
    dataframe.printSchema()
    dataframe.show(False)

if __name__=='__main__':
    predict_metrics()

执行以上代码后，出现以下错误：

TypeError: 'DataFrameReader' object is not callable

该错误的解决方法是什么？

Answer 1

如评论中所建议，应该session.read.format代替session.read().format

傻我！