我正在尝试创建一个pyspark dataframe，从Synapse Notebook读取日志分析表。
我使用了这个代码，但没有成功：
df_lg_tb = spark.read.format("com.microsoft.kusto.spark.datasource") \
.option("kustoCluster", "https://<workspace-id>.ods.opinsights.azure.com") \
.option("kustoDatabase", "<my-log-analytics-database-name>") \
.option("kustoQuery", "AzureActivity|take 10") \
.option("kustoAADUserId", "<workspace-id>") \
.option("kustoAADPassword", "<workspace-key>") \
.load()有谁知道另一种连接方式吗？
多谢了！
1条答案
按热度按时间23c0lvtd1#
在运行上述代码之前，请确保已添加日志分析工作区连接
到kustos星团就像下面这样。
检查您是否具有所有必需的权限和角色，并尝试运行上述代码。
如果这不起作用，您可以尝试以下方法作为解决方案。