From eac932eb827c93e2e998ac1210c3f5e548af0dbf Mon Sep 17 00:00:00 2001
From: qixiaoning <jony.kee@outlook.com>
Date: 星期四, 28 八月 2025 09:10:14 +0800
Subject: [PATCH] 推送回显地址bug,实时监控接口摄像机名称直接取video_point_name,
---
camera-service/models/milvus.go | 126 +++++++++++++++++++++---------------------
1 files changed, 63 insertions(+), 63 deletions(-)
diff --git a/camera-service/models/milvus.go b/camera-service/models/milvus.go
index 40f72de..0122ec7 100644
--- a/camera-service/models/milvus.go
+++ b/camera-service/models/milvus.go
@@ -1,63 +1,63 @@
-package models
-
-import (
- "context"
- "fmt"
- "log"
- "vamicro/api-gateway/models"
- commonModels "vamicro/camera-common/models"
-
- "github.com/milvus-io/milvus-sdk-go/v2/client"
-)
-
-var dbClient *MilvusClient
-
-// MilvusClient 灏佽Milvus鎿嶄綔鐨勭粨鏋勪綋
-type MilvusClient struct {
- client client.Client
-}
-
-// NewMilvusClient 鍒涘缓Milvus瀹㈡埛绔�
-func NewMilvusClient(ctx context.Context, addr string) (*MilvusClient, error) {
- milvusClient, err := client.NewGrpcClient(ctx, addr)
- if err != nil {
- return nil, fmt.Errorf("failed to connect to Milvus: %v", err)
- }
- return &MilvusClient{client: milvusClient}, nil
-}
-
-// Close 鍏抽棴杩炴帴
-func (m *MilvusClient) Close() error {
- return m.client.Close()
-}
-
-// 鍒濆鍖杕ilvus
-func InitVectorDb() {
- // 杩炴帴鍒癕ilvus鏈嶅姟鍣�
- ctx := context.Background()
- //milvusClient, err := NewMilvusClient(ctx, "192.168.1.232:19530")
-
- config := models.GetConfig()
- url := config.MilvusUrl
-
- milvusClient, err := NewMilvusClient(ctx, url)
- if err != nil {
- log.Fatal("Failed to connect to Milvus:", err)
- }
- //defer milvusClient.client.Close()
-
- fmt.Println("Successfully connected to Milvus")
-
- //鍒濆鍖�
- dbClient = milvusClient
- commonModels.SetClientDB(dbClient.client)
-}
-
-// GetDB ...
-func GetDBCient() *MilvusClient {
- return dbClient
-}
-
-func CloseDBClient() {
- dbClient.Close()
-}
+package models
+
+import (
+ "context"
+ "fmt"
+ "log"
+ "vamicro/api-gateway/models"
+ commonModels "vamicro/camera-common/models"
+
+ "github.com/milvus-io/milvus-sdk-go/v2/client"
+)
+
+var dbClient *MilvusClient
+
+// MilvusClient 灏佽Milvus鎿嶄綔鐨勭粨鏋勪綋
+type MilvusClient struct {
+ client client.Client
+}
+
+// NewMilvusClient 鍒涘缓Milvus瀹㈡埛绔�
+func NewMilvusClient(ctx context.Context, addr string) (*MilvusClient, error) {
+ milvusClient, err := client.NewGrpcClient(ctx, addr)
+ if err != nil {
+ return nil, fmt.Errorf("failed to connect to Milvus: %v", err)
+ }
+ return &MilvusClient{client: milvusClient}, nil
+}
+
+// Close 鍏抽棴杩炴帴
+func (m *MilvusClient) Close() error {
+ return m.client.Close()
+}
+
+// 鍒濆鍖杕ilvus
+func InitVectorDb() {
+ // 杩炴帴鍒癕ilvus鏈嶅姟鍣�
+ ctx := context.Background()
+ //milvusClient, err := NewMilvusClient(ctx, "192.168.1.232:19530")
+
+ config := models.GetConfig()
+ url := config.MilvusUrl
+
+ milvusClient, err := NewMilvusClient(ctx, url)
+ if err != nil {
+ log.Fatal("Failed to connect to Milvus:", err)
+ }
+ //defer milvusClient.client.Close()
+
+ fmt.Println("Successfully connected to Milvus")
+
+ //鍒濆鍖�
+ dbClient = milvusClient
+ commonModels.SetClientDB(dbClient.client)
+}
+
+// GetDB ...
+func GetDBCient() *MilvusClient {
+ return dbClient
+}
+
+func CloseDBClient() {
+ dbClient.Close()
+}
--
Gitblit v1.8.0