Databricks - запустить создание представления замены в консоли python

Question

создали фрейм данных ab c могу ли я запустить такой запрос sql, если не как, я не так гуд на python

введите описание изображения здесь

Query = "diff" colmnval = "456" if query == "diff": ab c .createorReplaceTempView ("XY_stg") else ab c .createorReplaceTempView ("XY_stg") СОЗДАТЬ ИЛИ ЗАМЕНИТЬ ВРЕМЕННОЕ ПРОСМОТРЕТЬ XY_stg как select *, '' as newperf from XY_stg, где column = {colmnval}

это код при попытке выхода в блокноте databricks, он включает как переменные ptyhon, так и sql оператор создания на основе представления при условии

Answer 1

Вы можете выполнить следующие шаги, чтобы создать представление замены в консоли python.

Вы можете изменить язык по умолчанию, указав язык magi c command %<language> в начале ячейки. Поддерживаемые команды magi c: %python, %r, %scala и %sql.

Шаг 1: Создание фрейма данных

df = spark.read.format("csv").option("sep", ",").options(header= "true", inferschema='true').option('escape','"').load("{0}".format(path))

Шаг 2: Создание временной таблицы

df.createOrReplaceTempView("Customer")

Step3: Проверка создания временной таблицы с помощью запроса SQL.

%sql show tables

Step4: Просмотр содержимого таблицы с помощью запроса SQL.

%sql select * from Customer 

введите описание изображения здесь