我怎麼能在火花SQL訪問python變量?

[haseebkhan1421]

我有python變量%下創建python在Azure磚jupyter筆記本文件。我怎麼能訪問相同的變量進行比較下% sql。下麵是例子:

% python

RunID_Goal = sqlContext。sql(“選擇CONCAT (SUBSTRING (RunID 1 6),“01 _”,子串(RunID 1 6),“01 _”)從RunID_Pace”)當代()[0]+ RunID_Pace 18: RunID_Goal

%的sql選擇類型、KPIDate價值從表在哪裏RunID = RunID_Goal(這是變量% python和想要比較下在這裏) 當我運行它拋出一個錯誤:錯誤的SQL語句:AnalysisException:不能解決“RunID_Goal”給定的輸入列:

我是新的sql azure磚和引發的任何形式的幫助,我們將不勝感激。

[User16752240003 · Accepted solution]

@haseebkhan1421,您可以創建一個臨時表在您的python細胞使用”DataFrame.createOrReplaceTempView (“table_name”)”和表的SQL查詢。檢查在這裏看到一個例子

[Kaniz]

嗨@haseebkhan1421,情況怎麼樣?

你能夠解決你的問題嗎?

[Nirupam]

spark.sql()中你可以使用{}pyspark / scala而不是sql細胞使用% sql。

這將導致dataframe。如果你想要你可以創建一個視圖在此之上使用createOrReplaceTempView ()

下麵是一個示例使用一個變量:-

#一個變量

var = " Hello World "

#使用f pyspark spark.sql。

火花。sql (f”“”選擇“{var}”作為信息”“”)

#使用格式

火花。sql(“”選擇“{}”作為信息”“.format (var))