pyspark 从 lakehouse读取delta 表 代码

Pyspark是从Apache Spark生态系统中用来进行大数据处理的Python库，它能够方便地操作数据仓库中的Delta表，Delta是一种基于Apache Parquet的数据湖存储格式，它支持事务、时间旅行以及即席查询。

要从Lakehouse中的Delta表读取数据，你可以使用`spark.read.format('delta')`来指定数据源格式为Delta，然后通过`.load()`方法加载表。这里是一个简单的例子：

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder.appName("Read Delta Table").getOrCreate()

# 指定Delta表的路径
table_path = "path_to_your_delta_table"

# 读取Delta表
df = spark.read.format("delta").load(table_path)

# 显示前几行数据查看是否成功读取
df.show(5)

# 关闭SparkSession（推荐做法，释放资源）
spark.stop()

在这个例子中，你需要将`"path_to_your_delta_table"`替换为你实际的Delta表路径。读取完成后，`df`就是包含表数据的DataFrame对象。