Azure Databricks python command to show current cluster config(Azure Databricks用于显示当前群集配置的python命令)
本文介绍了Azure Databricks用于显示当前群集配置的python命令的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我目前正在优化我们的ETL流程,并希望能够看到在处理数据时使用的现有集群配置。这样,我就可以随着时间的推移跟踪我应该使用哪些工作节点大小。有没有一个命令可以在python中返回集群工作线程#和大小,以便我可以以数据帧的形式写入?
推荐答案
您可以通过调用Cluster Get REST API获取此信息-它将返回json,包括工作进程的数量、节点类型等。
import requests
ctx = dbutils.notebook.entry_point.getDbutils().notebook().getContext()
host_name = ctx.tags().get("browserHostName").get()
host_token = ctx.apiToken().get()
cluster_id = ctx.tags().get("clusterId").get()
response = requests.get(
f'https://{host_name}/api/2.0/clusters/get?cluster_id={cluster_id}',
headers={'Authorization': f'Bearer {host_token}'}
).json()
num_workers = response['num_workers']
附注:如果您有非笔记本工作,则PAT令牌可能不可用,但您可以生成令牌并将其放在那里
这篇关于Azure Databricks用于显示当前群集配置的python命令的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
织梦狗教程
本文标题为:Azure Databricks用于显示当前群集配置的python命令
基础教程推荐
猜你喜欢
- 比较两个文本文件以找出差异并将它们输出到新的文本文件 2022-01-01
- Kivy 使用 opencv.调整图像大小 2022-01-01
- 究竟什么是“容器"?在蟒蛇?(以及所有的 python 容器类型是什么?) 2022-01-01
- kivy 应用程序中的一个简单网页作为小部件 2022-01-01
- Python 中是否有任何支持将长字符串转储为块文字或折叠块的 yaml 库? 2022-01-01
- 在 Python 中将货币解析为数字 2022-01-01
- Python,确定字符串是否应转换为 Int 或 Float 2022-01-01
- matplotlib 设置 yaxis 标签大小 2022-01-01
- 对多索引数据帧的列进行排序 2022-01-01
- 在 Django Admin 中使用内联 OneToOneField 2022-01-01
