能否直接将Snowpark DataFrame导出至Databricks？是否需先转存外部存储？

云上老周

2026-6-14

关于Snowpark DataFrame导出到Databricks的问题

目前没有原生的直接方法能把Snowpark DataFrame导出到Databricks平台，常规操作都是先将数据导出到双方都能访问的外部云存储（比如S3、ADLS、GCS），再由Databricks读取这些数据。
具体流程参考：
1. 用Snowpark的write API将DataFrame以Parquet、CSV这类通用格式写入共享云存储，示例代码：
```
snowpark_df.write.mode("overwrite").parquet("s3://your-shared-bucket/target-path")
```
2. 在Databricks中通过对应云存储的连接器读取文件，以S3为例：
```
databricks_df = spark.read.parquet("s3://your-shared-bucket/target-path")
```
还有一种间接方案：无需先导出到存储，在Databricks里通过Snowflake的JDBC/ODBC驱动直接连接Snowflake，查询读取对应数据生成DataFrame。这种方式是Databricks主动拉取Snowflake数据，和导出DataFrame的场景略有不同，示例代码：
```
conn_options = {
    "sfUrl": "your-snowflake-account-url",
    "sfUser": "your-username",
    "sfPassword": "your-password",
    "sfDatabase": "target-db",
    "sfSchema": "target-schema",
    "sfWarehouse": "your-warehouse"
}
databricks_df = spark.read.format("snowflake").options(**conn_options).option("query", "SELECT * FROM your-table").load()
```
这种方式需要确保Databricks拥有Snowflake的访问权限，且属于实时查询模式。