如何使用 azure databricks 执行 SQL 脚本
How to execute SQL scripts using azure databricks
我有一个 SQL 脚本文件
在该文件中有一些 sql 查询
我想将它上传到 dbfs 并从 azure databricks 读取它并从 azure databricks 上的脚本执行查询
Databricks 不直接支持执行 .sql 文件。但是，您可以将它们读入一个字符串并执行它们。
with open("/dbfs/path/to/query.sql") as queryFile:
queryText = queryFile.read()
results = spark.sql(queryText)
我有一个 SQL 脚本文件 在该文件中有一些 sql 查询 我想将它上传到 dbfs 并从 azure databricks 读取它并从 azure databricks 上的脚本执行查询
Databricks 不直接支持执行 .sql 文件。但是，您可以将它们读入一个字符串并执行它们。
with open("/dbfs/path/to/query.sql") as queryFile:
queryText = queryFile.read()
results = spark.sql(queryText)