Cluster（集群）
更新时间：2025-08-21
新建cluster
如下代码可以新建一个集群，集群包含1个master节点和2个core节点，且安装了Hive、Pig、HBase应用。请注意：参考下面样例代码时，需要修改log_uri参数指定BOS路径为您的账户可用的BOS路径。
Plain Text
1instance_groups = [
2 BmrClient.instance_group(
3 'Master',
4 'bmr.g1.xlarge ',
5 1,
6 'ig-master'
7 ),
8 BmrClient.instance_group(
9 'Core',
10 'bmr.g1.xlarge ',
11 3,
12 'ig-core'
13 )
14] # 构造请求体
15request_body = {
16 'applications': [
17 {
18 "name": "hive",
19 "version": "3.1.0"
20 },
21 {
22 "name": "pig",
23 "version": "0.17.0"
24 },
25 {
26 "name": "hbase",
27 "version": "2.2.7"
28 }
29 ],
30 'auto_terminate': False,
31 'admin_pass': '1234rewq!',
32 'name': 'sdk-cluster01',
33 'service_ha_enabled': False,
34 'safe_mode_enabled': False
35}
36
37try:
38 response = bmr_client.create_cluster(
39 'hadoop',
40 '2.2.1',
41 instance_groups,
42 **request_body)
43 cluster_id = response.cluster_id
44except BceHttpClientError as e:
45 if isinstance(e.last_error, BceServerError):
46 LOG.error('create_cluster failed. Response %s, code: %s, msg: %s'
47 % (e.last_error.status_code, e.last_error.code, e.last_error.args))
48 else:
49 LOG.error('create_cluster failed. Unknown exception: %s' % e)售卖的套餐类型请参考https://cloud.baidu.com/doc/BMR/s/6jwvxw85z
列出全部cluster
如下代码可以罗列出属于请求调用者的所有集群，用户可以通过配置查询参数max_keys来限制每次请求返回的集群数目:
Python
1try:
2 response = bmr_client.list_clusters(max_keys=5)
3 LOG.debug('list total %s clusters' % len(response.clusters))
4 # 输出各个集群的信息
5 for cluster in response.clusters:
6 LOG.debug('cluster: %s' % cluster)
7except BceHttpClientError as e:
8 if isinstance(e.last_error, BceServerError):
9 LOG.error('list_clusters failed. Response %s, code: %s, msg: %s'
10 % (e.last_error.status_code, e.last_error.code, e.last_error.args))
11 else:
12 LOG.error('list_clusters failed. Unknown exception: %s' % e)另外，也可以使用分页查询的方式来获取所有集群，通过配置max_keys来限制每页查询返回的集群数目：
Python
1try:
2 page = 1
3 next_marker = None
4 max_keys = 5
5 is_truncated = True
6 while is_truncated:
7 response = bmr_client.list_clusters(marker=next_marker, max_keys=max_keys)
8 LOG.debug('list %s clusters on Page %s' % (len(response.clusters), page))
9 page += 1
10 is_truncated = response.is_truncated
11 next_marker = response.next_marker
12except BceHttpClientError as e:
13 if isinstance(e.last_error, BceServerError):
14 LOG.error('list_clusters failed. Response %s, code: %s, msg: %s'
15 % (e.last_error.status_code, e.last_error.code, e.last_error.args))
16 else:
17 LOG.error('list_clusters failed. Unknown exception: %s' % e)查询指定的cluster
获取了集群ID后，可用如下代码查询指定集群的信息：
Python
1try:
2 response = bmr_client.get_cluster(cluster_id)
3 # 输出集群的状态信息
4 status = response.status.state
5 LOG.debug('check cluster %s: status %s' % (cluster_id, status))
6except BceHttpClientError as e:
7 if isinstance(e.last_error, BceServerError):
8 LOG.error('get_cluster failed. Response %s, code: %s, msg: %s'
9 % (e.last_error.status_code, e.last_error.code, e.last_error.args))
10 else:
11 LOG.error('describe_cluster failed. Unknown exception: %s' % e)终止指定的cluster
如下代码可以终止指定的集群：
Python
1try:
2 response = bmr_client.terminate_cluster(cluster_id)
3 LOG.debug('terminate cluster %s: status %s' % (cluster_id, response.status))
4except BceHttpClientError as e:
5 if isinstance(e.last_error, BceServerError):
6 LOG.error('terminate_cluster failed. Response %s, code: %s, msg: %s'
7 % (e.last_error.status_code, e.last_error.code, e.last_error.args))
8 else:
9 LOG.error('terminate_cluster failed. Unknown exception: %s' % e)