floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update api url of getting task info with index level

This commit is contained in:
liugq 2023-03-29 10:26:05 +08:00
parent 633d0333f2
commit 305a11ec40
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
plugin/migration/api.go
View File

@ -37,7 +37,7 @@ func InitAPI() {
api.HandleAPIMethod(api.POST, "/migration/data/:task_id/_stop", handler.RequireLogin(handler.stopDataMigrationTask)) api.HandleAPIMethod(api.POST, "/migration/data/:task_id/_stop", handler.RequireLogin(handler.stopDataMigrationTask))
//api.HandleAPIMethod(api.GET, "/migration/data/:task_id", handler.getMigrationTask) //api.HandleAPIMethod(api.GET, "/migration/data/:task_id", handler.getMigrationTask)
api.HandleAPIMethod(api.GET, "/migration/data/:task_id/info", handler.RequireLogin(handler.getDataMigrationTaskInfo)) api.HandleAPIMethod(api.GET, "/migration/data/:task_id/info", handler.RequireLogin(handler.getDataMigrationTaskInfo))
api.HandleAPIMethod(api.GET, "/migration/data/:task_id/info/:index/:doc_type", handler.RequireLogin(handler.getDataMigrationTaskOfIndex)) api.HandleAPIMethod(api.GET, "/migration/data/:task_id/info/:index", handler.RequireLogin(handler.getDataMigrationTaskOfIndex))
api.HandleAPIMethod(api.PUT, "/migration/data/:task_id/status", handler.RequireLogin(handler.updateDataMigrationTaskStatus)) api.HandleAPIMethod(api.PUT, "/migration/data/:task_id/status", handler.RequireLogin(handler.updateDataMigrationTaskStatus))
} }
@ -632,8 +632,7 @@ func getIndexTaskDocCount(index *IndexConfig, targetESClient elastic.API) (int64
func (h *APIHandler) getDataMigrationTaskOfIndex(w http.ResponseWriter, req *http.Request, ps httprouter.Params){ func (h *APIHandler) getDataMigrationTaskOfIndex(w http.ResponseWriter, req *http.Request, ps httprouter.Params){
id := ps.MustGetParameter("task_id") id := ps.MustGetParameter("task_id")
indexName := ps.MustGetParameter("index") uniqueIndexName := ps.MustGetParameter("index")
docType := ps.MustGetParameter("doc_type")
majorTask := task2.Task{} majorTask := task2.Task{}
majorTask.ID = id majorTask.ID = id
exists, err := orm.Get(&majorTask) exists, err := orm.Get(&majorTask)
@ -670,7 +669,7 @@ func (h *APIHandler) getDataMigrationTaskOfIndex(w http.ResponseWriter, req *htt
{ {
"term": util.MapStr{ "term": util.MapStr{
"metadata.labels.unique_index_name": util.MapStr{ "metadata.labels.unique_index_name": util.MapStr{
"value": fmt.Sprintf("%s:%s", indexName, docType), "value": uniqueIndexName,
}, },
}, },
}, },