EMR 常见问题?

集群列表

1. #!/usr/bin/python
3. from aliyunsdkcore import client
4. from aliyunsdkemr.request.v20160408 import ListClustersRequest
6. clt = client.AcsClient('SFAW************','Nc2nZ6dQoiqck0*************', ,'cn-hangzhou') # set acessId and accessKey
7. request = ListClustersRequest.ListClustersRequest()
8. request.set_accept_format('xml') # xml or json
9. # 设置状态过滤，只查找RUNNING和IDLE的集群，注意该参数为选填参数，可以不设置
10. request.add_query_param('StatusList.1', 'RUNNING')
11. request.add_query_param('StatusList.2', 'IDLE')
12. result = clt.do_action(request)
13. print result

1. #!/usr/bin/python
3. from aliyunsdkcore import client
4. from aliyunsdkemr.request.v20160408 import CreateClusterRequest
6. clt = client.AcsClient('SFAW************','Nc2nZ6dQoiqck0*************', ,'cn-hangzhou') # set acessId and accessKey
7. request = CreateClusterRequest.CreateClusterRequest()
8. request.set_Name("pydemo")
9. request.set_ZoneId("cn-hangzhou-b")
10. request.set_LogEnable(False)
11. request.set_SecurityGroupId("sg-********")
12. request.set_IsOpenPublicIp(True)
13. request.set_ChargeType("PostPaid")
14. request.set_EmrVer("EMR-1.3.0")
15. request.set_ClusterType("HADOOP")
16. request.set_IoOptimized(True)
17. request.set_InstanceGeneration("ecs-2")
19. # set EcsOrder
20. request.add_query_param('EcsOrder.1.NodeCount', '1')
21. request.add_query_param('EcsOrder.1.NodeType', 'MASTER')
22. request.add_query_param('EcsOrder.1.InstanceType', 'ecs.n1.large')
23. request.add_query_param('EcsOrder.1.DiskType', 'CLOUD_EFFICIENCY')
24. request.add_query_param('EcsOrder.1.DiskCapacity', '80')
25. request.add_query_param('EcsOrder.1.DiskCount', '1')
26. request.add_query_param('EcsOrder.1.Index', '1')
28. request.add_query_param('EcsOrder.2.NodeCount', '3')
29. request.add_query_param('EcsOrder.2.NodeType', 'CORE')
30. request.add_query_param('EcsOrder.2.InstanceType', 'ecs.n1.large')
31. request.add_query_param('EcsOrder.2.DiskType', 'CLOUD_EFFICIENCY')
32. request.add_query_param('EcsOrder.2.DiskCapacity', '80')
33. request.add_query_param('EcsOrder.2.DiskCount', '4')
34. request.add_query_param('EcsOrder.2.Index', '2')
36. request.set_accept_format('json')
38. result = clt.do_action(request)
39. print result

注意，由于阿里云产品众多，所有SDK的生成是通过程序自动生成的，所以有些SDK的使用比较不方便，特别地，在目前PythonSDK中，对入参是List（不管是基本类型的List还是复杂对象的List）支持不好，需要特殊处理。如果是基本类型的List入参，请参考“集群列表”示例代码中对StatusList参数的设置，如果是复杂对象的List入参，请参考“创建集群”示例代码中对EcsOrder参数的设置。其它List入参，例如BootstrapAction参数如果需要使用的话，处理方式类似。JavaSDK没有类似问题，使用起来会更加方便，我们优先 推荐您使用Java SDK。