Есть ли способ использовать операцию DML в SNOWflake с помощью pyspark, я могу запустить оператор выбора, но сталкиваюсь с проблемой в слиянии или создании оператора

Question

Есть ли способ использовать операцию DML в SNOWflake с использованием pyspark, я могу запустить оператор select, но сталкиваюсь с проблемой при слиянии или создании оператора

Answer 1

Пожалуйста, проверьте, помогает ли это.

import snowflake.connector
ctx = snowflake.connector.connect(
    user='u-name',
    account='account',
    warehouse='wh-hane',
    database='db-name',
    schema='schema-name'
    )

cs = ctx.cursor()
try:
    cs.execute("USE WAREHOUSE xxx")
    cs.execute("USE DATABASE xxx")
    cs.execute("USE SCHEMA xxx")
    cs.execute("my-query")

finally:
    cs.close()


ctx.close()

Answer 2

С Spark Connector вы можете запускать запросы DML в scala. Используйте метод runQuery () объекта Utils для выполнения операторов DDL / DML SQL в дополнение к запросам, например: https://docs.snowflake.com/en/user-guide/spark-connector-use.html#executing -ddl-dml- sql -statements Если вы при использовании Python необходимо использовать разъем Python, а не разъем Spark.