我大约有55个EMR集群(它们都已终止),并且一直在尝试使用 boto 中的 list_clusters 方法检索整个55个EMR集群.我一直在寻找有关从boto分页结果集数量的示例,但找不到任何示例.鉴于此声明:
I have about 55 EMR clusters (all of them were terminated) and have been trying to retrieve the entire 55 EMR clusters using the list_clusters method in boto. I've been searching for examples about paginating the number of result set from boto but couldn't find any examples. Given this statement:
emr_object.list_clusters(cluster_states=["TERMINATED"], marker="what_should_i_use_here").clusters我不断收到 InvalidRequestException 错误:
boto.exception.EmrResponseError: EmrResponseError: 400 Bad Request <ErrorResponse xmlns="elasticmapreduce.amazonaws/doc/2009-03-31"> <Error> <Type>Sender</Type> <Code>InvalidRequestException</Code> <Message>Marker 'what_should_i_use_here' is not valid.</Message> </Error> <RequestId>555b91bd-c122-11e3-8e31-abc75abdb39d</RequestId> </ErrorResponse>我应该在 marker 参数中提供什么,以便我可以正确地对查询进行分页?
What should I provide in marker param so that I can properly paginate the query?
谢谢!
推荐答案您可以在第一轮通过无"操作.
You can pass in None the first time round.
如果返回的ClusterListResult具有marker属性,则可以稍后再传递该属性,例如
If the ClusterListResult you get back has a marker attribute then you can pass that in later, e.g.
m=None while True: try: cluster_list_result=emr_object.describe_jobflows(states=['TERMINATED'], marker=m) .... Do whatever with cluster_list_result.clusters m=cluster_list_result.marker # See if there are more except AttributeError: break更多推荐
无法使用Boto对EMR集群进行分页
发布评论