如何在 SnowPark 中读取 csv

【问题标题】：How to you read a csv in SnowPark如何在 SnowPark 中读取 csv
【发布时间】：2022-01-05 13:33:53
【问题描述】：

我有一堆 .csv 文件，我正在寻找将它们加载到 SnowPark 的最简单方法？我不确定需要哪些 API。如果有人可以向我指出 API 或提供一个很棒的代码示例。

谢谢

【问题讨论】：

【解决方案1】：

我不认为您可以直接一步完成此操作，因为 Snowpark 没有相应的 API。你可以做的是：

将 CSV 文件加载到阶段。

// Upload a file to a stage.
session.file.put("file:///tmp/file1.csv", "@myStage/prefix1")

通过从舞台读取文件来创建一个DataFrame。

val dfCatalog = session.read.csv("@myStage/prefix1")

查看更多信息here 和 here 和 here

【讨论】：