身安不如心安,屋宽不如心宽 。

elasticsearch _tasks 获取描述信息

Elasticsearch | 作者 juin | 发布于2020年03月24日 | 阅读数:3655

aaa.png


elasticsearch 6.1.1
求教,这里的描述信息 description 怎么在 GET _tasks 时通过参数匹配到呢?
 
想在批量更新时,实时通过索引名来获取更新进度
 
已邀请:

God_lockin

赞同来自: byx313 juin

貌似api里不支持那么多参数,一眼看过去只有这些参数可以用
detailed,nodes,actions,parent_task_id,wait_for_completion,timeout
 
所以估计你得自己写代码过滤description了。
 
在`org.elasticsearch.rest.action.admin.cluster.RestListTasksAction`里面
public static ListTasksRequest generateListTasksRequest(RestRequest request) {
boolean detailed = request.paramAsBoolean("detailed", false);
String[] nodes = Strings.splitStringByCommaToArray(request.param("nodes"));
String[] actions = Strings.splitStringByCommaToArray(request.param("actions"));
TaskId parentTaskId = new TaskId(request.param("parent_task_id"));
boolean waitForCompletion = request.paramAsBoolean("wait_for_completion", false);
TimeValue timeout = request.paramAsTime("timeout", null);

ListTasksRequest listTasksRequest = new ListTasksRequest();
listTasksRequest.setNodes(nodes);
listTasksRequest.setDetailed(detailed);
listTasksRequest.setActions(actions);
listTasksRequest.setParentTaskId(parentTaskId);
listTasksRequest.setWaitForCompletion(waitForCompletion);
listTasksRequest.setTimeout(timeout);
return listTasksRequest;
}
 
 
 

juin - 大数据开发

赞同来自:

(┬_┬)

juin - 大数据开发

赞同来自:

主要考虑有多个批量更新时,我能根据指定的索引名过滤出来需要的那个 task

要回复问题请先登录注册