如何通过Spark连接器读取带引号创建的Snowflake表？

当使用Spark Snowflake连接器读取普通表时，如下代码可正常运行：

df = spark.read.format("snowflake") \
               .options(**sfParams) # 存储所有Snowflake凭据的字典 \
               .option('dbtable', 'TABLE1').load()

但如果Snowflake中的表是通过带引号语句创建的（例如CREATE TABLE DB1.SCHEMA1."MY.TABLE2"），直接使用option('dbtable', '"MY.TABLE2"')会抛出错误：invalid URL prefix found in: 'MY.TABLE2'。

以下是两种可行的解决方案：

方案1：指定完整的带引号表标识符 #

将数据库、模式和表名组成完整的标识符，确保特殊表名被双引号正确包裹：

df = spark.read.format("snowflake") \
             .options(**sfParams) \
             .option('dbtable', 'DB1.SCHEMA1."MY.TABLE2"').load()

若数据库或模式名也包含特殊字符，同样需要用双引号包裹，例如"DB1"."SCHEMA1"."MY.TABLE2"。

方案2：使用query参数替代dbtable #

通过SQL查询语句读取表，这种方式能更灵活处理特殊命名的表：

df = spark.read.format("snowflake") \
             .options(**sfParams) \
             .option('query', 'SELECT * FROM DB1.SCHEMA1."MY.TABLE2"').load()

错误原因说明 #

直接传入"MY.TABLE2"作为dbtable参数时，连接器会将.解析为数据库/模式与表的分隔符，误将其识别为MY库下的TABLE2表，从而触发URL格式相关错误。

内容的提问来源于stack exchange，提问作者Anirban Nag 'tintinmj'