如何使用pyspark dataframe将数据存储到具有时间戳TIMESTAMP_NTZ的雪花中

Question

PY4JJavaError：调用O2088.Save时出错。：net.snowflake.client.jdbc.snowflakesqlexception:无法识别时间戳'2020-06-15t12:00:20.040z'文件'nvefrmawkn.csv'，第1行，字符63第1行，列“_test1”[“time_test1”:4]如果在遇到错误时希望继续加载，请使用其他值，如'skip_file'或'continue'作为ON_ERROR选项。有关加载选项的详细信息，请在SQL客户端中运行'info loading_data'。在.java:529)在net.snowflake.client.jdbc.snowflakeStatementv1.executeinternal(snowflakeStatementv1.java:204)在net.snowflake.client.jdbc.snowflake.jdbc.snowflakeStatementv1.java:204)在net.snowflake.spark.snowflake.jdbc.snowflakeStatementv1.execute(snowflakeStatementv1.java:239)在snowflake.spark.snowflake.jdbcwrapper$$anonfun$3.apply(snowflakejdbcwrapper.scala:283)在scala.concurrent.impl.future$promiseCompleTingrunnable.liftedTree1$1(Future.scala:24)在scala.concurrent.impl.future$promiseCompleTingrunnable.run(Future.scala:24)在java.util.concurrent.ThreadPoolExecutor.runworker（ThreadPoolExecutor.java:1149)在java.util.concurrent.ThreadPoolExecutor.worker.run（

Answer 1

您可以尝试将timestamp参数更改为：

“timestamp_ntz_output_format”：“yyyyy-mm-ddthh24:mi:ss.ff3z”

此格式与您在文章中显示的格式相匹配，因此它可能会解决您的问题。