【问题标题】:Databricks - Run create replace view in python consoleDatabricks - 在 python 控制台中运行创建替换视图
【发布时间】:2020-07-09 11:02:15
【问题描述】:

已经创建了一个 datframe abc 我可以像这样运行一个 sql 查询,如果不是如何,我对 python 不那么熟悉

enter image description here

Query="diff" colmnval="456" if query == "diff": abc.createorReplaceTempView("XY_stg") else abc.createorReplaceTempView("XY_stg") CREATE OR REPLACE TEMPORARY VIEW XY_stg as select *,''作为来自 XY_stg 的 newperf,其中 column={colmnval}

这是试图在 databricks 笔记本中执行的代码,它包含 ptyhon 变量和基于条件创建视图的 sql 语句

【问题讨论】:

  • 请提供有关您的问题的更多详细信息。您的代码是什么样的(包括实际代码,而不是图片)。你试过什么,你卡在哪里了?如果您收到任何错误消息,它们也可能有助于回答您的问题。
  • query="diff" colmnval="456" if query == "diff": abc.createorReplaceTempView("XY_stg") else abc.createorReplaceTempView("XY_stg") 创建或替换临时视图 XY_stg as select *,'' as newperf from XY_stg where column={colmnval}
  • 这是试图在 databricks 笔记本中执行的代码,它包含 ptyhon 变量和基于条件创建视图的 sql 语句
  • 请使用“编辑”按钮使用附加信息更新您的问题。见stackoverflow.com/help/how-to-ask。关于您的问题,您似乎将 SQL 和 python 混合在一个单元格中。使用其中之一,而不是两者。通过将%sql%python 作为单元格的第一行,您可以在两者之间切换,请参阅docs.databricks.com/notebooks/notebooks-use.html#mix-languages
  • @malcolmrichard,如果我的回答对您有帮助,您可以接受它作为答案(单击答案旁边的复选标记将其从灰色切换为已填充。)。这对其他社区成员可能是有益的。谢谢。

标签: python databricks azure-databricks


【解决方案1】:

您可以按照以下步骤在 python 控制台中创建替换视图。

您可以通过在单元格开头指定语言魔术命令 %<language> 来覆盖默认语言。支持的魔法命令有:%python%r%scala%sql .

第一步:创建数据框

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

第二步:创建临时表

df.createOrReplaceTempView("Customer")

Step3:检查是否使用SQL查询创建了临时表。

%sql show tables

Step4:使用SQL查询查看表格内容。

%sql select * from Customer 

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2011-09-04
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多