Запрос об ошибке возврата соединителя искры снежинки ⇐ Python

[Anonymous]

Я пытаюсь выполнить запрос, используя искры-снежинки, код выглядит следующим образом:

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

command = f'''insert into {NewTable} ({Newcolumn})
select  {column} from {Table} {Where}'''
print(command)
df = spark.read.format(snowflake_source_name) \
.options(**snowflake_options) \
.option("query", command) \
.load()

результат печати выглядит следующим образом:

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

insert into Process.dim_ICON (ICON,dim_ICON_Key)
select  ICON, ROW_NUMBER() OVER (ORDER BY ICON) from APIDATA

однако, когда я запускаю код, он возвращает ошибку:

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

2024-12-01 16:36:44 ERROR    error:An error occurred while calling o302.load.
: net.snowflake.client.jdbc.SnowflakeSQLException: SQL compilation error:
syntax error line 1 at position 15 unexpected 'insert'.
syntax error line 1 at position 62 unexpected ')'.

где эта ошибка не возникнет при работе в Snowflake SQL
Сценарий должен выполнить запрос

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

insert into Process.dim_ICON (ICON,dim_ICON_Key)
select  ICON, ROW_NUMBER() OVER (ORDER BY ICON) from APIDATA

с помощью соединителя pysparks

Подробнее здесь: https://stackoverflow.com/questions/792 ... turn-error