Refine log of CreatePartition (#12693)

Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>

internal/proxy/impl.go

@@ -693,6 +693,11 @@ func (node *Proxy) CreatePartition(ctx context.Context, request *milvuspb.Create
 	if !node.checkHealthy() {
 		return unhealthyStatus(), nil
 	}
+
+	sp, ctx := trace.StartSpanFromContextWithOperationName(ctx, "Proxy-Insert")
+	defer sp.Finish()
+	traceID, _, _ := trace.InfoFromSpan(sp)
+
 	cpt := &createPartitionTask{
 		ctx:                    ctx,
 		Condition:              NewTaskCondition(ctx),
@@ -701,44 +706,71 @@ func (node *Proxy) CreatePartition(ctx context.Context, request *milvuspb.Create
 		result:                 nil,
 	}
 
-	log.Debug("CreatePartition enqueue",
+	log.Debug(
+		rpcReceived("CreatePartition"),
+		zap.String("traceID", traceID),
 		zap.String("role", Params.RoleName),
 		zap.String("db", request.DbName),
 		zap.String("collection", request.CollectionName),
 		zap.String("partition", request.PartitionName))
-	err := node.sched.ddQueue.Enqueue(cpt)
-	if err != nil {
+
+	if err := node.sched.ddQueue.Enqueue(cpt); err != nil {
+		log.Warn(
+			rpcFailedToEnqueue("CreatePartition"),
+			zap.Error(err),
+			zap.String("traceID", traceID),
+			zap.String("role", Params.RoleName),
+			zap.String("db", request.DbName),
+			zap.String("collection", request.CollectionName),
+			zap.String("partition", request.PartitionName))
+
 		return &commonpb.Status{
 			ErrorCode: commonpb.ErrorCode_UnexpectedError,
 			Reason:    err.Error(),
 		}, nil
 	}
 
-	log.Debug("CreatePartition",
+	log.Debug(
+		rpcEnqueued("CreatePartition"),
+		zap.String("traceID", traceID),
 		zap.String("role", Params.RoleName),
-		zap.Int64("msgID", request.Base.MsgID),
-		zap.Uint64("timestamp", request.Base.Timestamp),
+		zap.Int64("MsgID", cpt.ID()),
+		zap.Uint64("BeginTS", cpt.BeginTs()),
+		zap.Uint64("EndTS", cpt.EndTs()),
 		zap.String("db", request.DbName),
 		zap.String("collection", request.CollectionName),
 		zap.String("partition", request.PartitionName))
-	defer func() {
-		log.Debug("CreatePartition Done",
+
+	if err := cpt.WaitToFinish(); err != nil {
+		log.Warn(
+			rpcFailedToWaitToFinish("CreatePartition"),
 			zap.Error(err),
+			zap.String("traceID", traceID),
 			zap.String("role", Params.RoleName),
-			zap.Int64("msgID", request.Base.MsgID),
-			zap.Uint64("timestamp", request.Base.Timestamp),
+			zap.Int64("MsgID", cpt.ID()),
+			zap.Uint64("BeginTS", cpt.BeginTs()),
+			zap.Uint64("EndTS", cpt.EndTs()),
 			zap.String("db", request.DbName),
 			zap.String("collection", request.CollectionName),
 			zap.String("partition", request.PartitionName))
-	}()
 
-	err = cpt.WaitToFinish()
-	if err != nil {
 		return &commonpb.Status{
 			ErrorCode: commonpb.ErrorCode_UnexpectedError,
 			Reason:    err.Error(),
 		}, nil
 	}
+
+	log.Debug(
+		rpcDone("CreatePartition"),
+		zap.String("traceID", traceID),
+		zap.String("role", Params.RoleName),
+		zap.Int64("MsgID", cpt.ID()),
+		zap.Uint64("BeginTS", cpt.BeginTs()),
+		zap.Uint64("EndTS", cpt.EndTs()),
+		zap.String("db", request.DbName),
+		zap.String("collection", request.CollectionName),
+		zap.String("partition", request.PartitionName))
+
 	return cpt.result, nil
 }
 

internal/proxy/rpc_msg.go

+// Licensed to the LF AI & Data foundation under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package proxy
+
+import "fmt"
+
+func rpcReceived(method string) string {
+	return fmt.Sprintf("%s received", method)
+}
+
+func rpcEnqueued(method string) string {
+	return fmt.Sprintf("%s enqueued", method)
+}
+
+func rpcDone(method string) string {
+	return fmt.Sprintf("%s done", method)
+}
+
+func rpcFailedToEnqueue(method string) string {
+	return fmt.Sprintf("%s failed to enqueue", method)
+}
+
+func rpcFailedToWaitToFinish(method string) string {
+	return fmt.Sprintf("%s failed to WaitToFinish", method)
+}