Net.snowflake.client.jdbc.SnowflakeSQLException: токен JWT недействителен ⇐ Python

[Anonymous]

Я не могу подключиться к снежинке с помощью pyspark в блоках данных.

Код: Выделить всё

def readFromSnowflake():
private_key = ""
sfOptions = {
"sfURL": "swiggy.ap-southeast-1.snowflakecomputing.com",
"sfUser": "",
"sfDatabase": "",
"sfSchema": "",
"sfWarehouse": "",
"sfRole": "",
"pem_private_key": private_key
}
query = ""
SNOWFLAKE_SOURCE_NAME = "net.snowflake.spark.snowflake"
df = spark.read.format(SNOWFLAKE_SOURCE_NAME).options(**sfOptions).option("query", query).load()
df.show(10)

readFromSnowflake()

когда я запускаю приведенный выше код в блокноте databricks, я получаю ошибку ниже

Код: Выделить всё

Py4JJavaError: An error occurred while calling o318.load.
: net.snowflake.client.jdbc.SnowflakeSQLException: JWT token is invalid.
at net.snowflake.client.core.SessionUtil.newSession(SessionUtil.java:585)
at net.snowflake.client.core.SessionUtil.openSession(SessionUtil.java:272)
at net.snowflake.client.core.SFSession.open(SFSession.java:543)
at net.snowflake.client.jdbc.SnowflakeConnectionV1.initialize(SnowflakeConnectionV1.java:167)
at net.snowflake.client.jdbc.SnowflakeConnectionV1.(SnowflakeConnectionV1.java:119)
at net.snowflake.client.jdbc.SnowflakeDriver.connect(SnowflakeDriver.java:169)
at java.sql.DriverManager.getConnection(DriverManager.java:664)
at java.sql.DriverManager.getConnection(DriverManager.java:208)
at net.snowflake.spark.snowflake.JDBCWrapper.getConnector(SnowflakeJDBCWrapper.scala:214)
at net.snowflake.spark.snowflake.SnowflakeRelation$$anonfun$schema$1.apply(SnowflakeRelation.scala:61)
at net.snowflake.spark.snowflake.SnowflakeRelation$$anonfun$schema$1.apply(SnowflakeRelation.scala:58)
at scala.Option.getOrElse(Option.scala:121)
at net.snowflake.spark.snowflake.SnowflakeRelation.schema$lzycompute(SnowflakeRelation.scala:58)
at net.snowflake.spark.snowflake.SnowflakeRelation.schema(SnowflakeRelation.scala:57)
at org.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:454)
at org.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:307)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:293)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:203)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:380)
at py4j.Gateway.invoke(Gateway.java:295)
at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
at py4j.commands.CallCommand.execute(CallCommand.java:79)
at py4j.GatewayConnection.run(GatewayConnection.java:251)
at java.lang.Thread.run(Thread.java:748)

Может ли кто-нибудь помочь мне, в чем может быть причина проблемы? Но я уверен, что остальные параметры, которые я передаю в sf_option, верны.

Подробнее здесь: https://stackoverflow.com/questions/673 ... is-invalid