feat: Chat supports Q&A nodes (#207)

Co-authored-by: yangyu.1 <yangyu.1@bytedance.com>

.github/CODEOWNERS

@@ -150,6 +150,7 @@
 /frontend/packages/studio/publish-manage-hooks/ @duwenhan2byte @evan-crash
 /frontend/packages/foundation/layout/ @evan-crash @duwenhan2byte
 /frontend/packages/studio/open-platform/open-auth/ @evan-crash @DingGao-Devin
+/frontend/packages/studio/open-platform/open-chat/ @tomasyu985 @DingGao-Devin
 /frontend/packages/agent-ide/entry-adapter/ @Hezi-crypto @duwenhan2byte @catee @evan-crash @haozhenfei
 /frontend/packages/agent-ide/entry/ @soonco @duwenhan2byte @catee @evan-crash
 /frontend/packages/agent-ide/bot-config-area-adapter/ @haozhenfei @Hezi-crypto @duwenhan2byte @catee @evan-crash

CONTRIBUTING.md

@@ -28,7 +28,7 @@ Before you submit your Pull Request (PR) consider the following guidelines:
 3. [Fork](https://docs.github.com/en/github/getting-started-with-github/fork-a-repo) the coze-dev {project_name} repo.
 4. In your forked repository, make your changes in a new git branch:
     ```
-    git checkout -b my-fix-branch develop
+    git checkout -b my-fix-branch main
     ```
 5. Create your patch, including appropriate test cases.
 6. Follow our [Style Guides](#code-style-guides).
@@ -38,7 +38,7 @@ Before you submit your Pull Request (PR) consider the following guidelines:
     ```
     git push origin my-fix-branch
     ```
-9. In GitHub, send a pull request to `{project_name}:develop`
+9. In GitHub, send a pull request to `{project_name}:main`
 
 ## Contribution Prerequisites
 - Our development environment keeps up with [Go Official](https://golang.org/project/).

Makefile

@@ -28,7 +28,7 @@ fe:
 	@echo "Building frontend..."
 	@bash $(BUILD_FE_SCRIPT)
 
-server: env 
+server: env setup_es_index
 	@if [ ! -d "$(STATIC_DIR)" ]; then \
 		echo "Static directory '$(STATIC_DIR)' not found, building frontend..."; \
 		$(MAKE) fe; \

backend/api/model/crossdomain/plugin/toolinfo.go

@@ -263,6 +263,7 @@ func toAPIParameter(paramMeta paramMetaInfo, sc *openapi3.Schema) (*common.APIPa
 	}
 
 	if sc.Default != nil {
+		apiParam.GlobalDefault = ptr.Of(fmt.Sprintf("%v", sc.Default))
 		apiParam.LocalDefault = ptr.Of(fmt.Sprintf("%v", sc.Default))
 	}
 

backend/application/base/pluginutil/api.go

@@ -20,9 +20,8 @@ import (
 	"net/http"
 	"strconv"
 
-	"github.com/getkin/kin-openapi/openapi3"
-
 	"github.com/coze-dev/coze-studio/backend/domain/plugin/entity"
+	"github.com/getkin/kin-openapi/openapi3"
 
 	"github.com/coze-dev/coze-studio/backend/api/model/crossdomain/plugin"
 	common "github.com/coze-dev/coze-studio/backend/api/model/plugin_develop_common"
@@ -33,14 +32,6 @@ import (
 func APIParamsToOpenapiOperation(reqParams, respParams []*common.APIParameter) (*openapi3.Operation, error) {
 	op := &openapi3.Operation{}
 
-	if reqParams != nil && len(reqParams) == 0 {
-		op.Parameters = []*openapi3.ParameterRef{}
-		op.RequestBody = entity.DefaultOpenapi3RequestBody()
-	}
-	if respParams != nil && len(respParams) == 0 {
-		op.Responses = entity.DefaultOpenapi3Responses()
-	}
-
 	hasSetReqBody := false
 	hasSetParams := false
 
@@ -136,6 +127,16 @@ func APIParamsToOpenapiOperation(reqParams, respParams []*common.APIParameter) (
 		}
 	}
 
+	if op.Parameters == nil {
+		op.Parameters = []*openapi3.ParameterRef{}
+	}
+	if op.RequestBody == nil {
+		op.RequestBody = entity.DefaultOpenapi3RequestBody()
+	}
+	if op.Responses == nil {
+		op.Responses = entity.DefaultOpenapi3Responses()
+	}
+
 	return op, nil
 }
 

backend/application/knowledge/init.go

@@ -36,6 +36,7 @@ import (
 	"github.com/cloudwego/eino-ext/components/model/qwen"
 	"github.com/cloudwego/eino/components/prompt"
 	"github.com/cloudwego/eino/schema"
+	"github.com/coze-dev/coze-studio/backend/infra/impl/embedding/http"
 	"github.com/milvus-io/milvus/client/v2/milvusclient"
 	"github.com/volcengine/volc-sdk-golang/service/vikingdb"
 	"github.com/volcengine/volc-sdk-golang/service/visual"
@@ -371,6 +372,21 @@ func getEmbedding(ctx context.Context) (embedding.Embedder, error) {
 			return nil, fmt.Errorf("init ollama embedding failed, err=%w", err)
 		}
 
+
+	case "http":
+		var (
+			httpEmbeddingBaseURL = os.Getenv("HTTP_EMBEDDING_ADDR")
+			httpEmbeddingDims    = os.Getenv("HTTP_EMBEDDING_DIMS")
+		)
+		dims, err := strconv.ParseInt(httpEmbeddingDims, 10, 64)
+		if err != nil {
+			return nil, fmt.Errorf("init http embedding dims failed, err=%w", err)
+		}
+		emb, err = http.NewEmbedding(httpEmbeddingBaseURL, dims)
+		if err != nil {
+			return nil, fmt.Errorf("init http embedding failed, err=%w", err)
+		}
+
 	default:
 		return nil, fmt.Errorf("init knowledge embedding failed, type not configured")
 	}

backend/application/plugin/plugin.go

@@ -250,7 +250,7 @@ func (p *PluginApplicationService) RegisterPluginMeta(ctx context.Context, req *
 		if req.GetLocation() == common.AuthorizationServiceLocation_Query {
 			loc = model.ParamInQuery
 		} else if req.GetLocation() == common.AuthorizationServiceLocation_Header {
-			loc = model.ParamInPath
+			loc = model.ParamInHeader
 		} else {
 			return nil, fmt.Errorf("invalid location '%s'", req.GetLocation())
 		}

backend/domain/knowledge/service/knowledge_integration_test.go

@@ -145,7 +145,7 @@ func (suite *KnowledgeTestSuite) SetupSuite() {
 		panic(err)
 	}
 
-	emb, err := hembed.NewEmbedding(embEndpoint)
+	emb, err := hembed.NewEmbedding(embEndpoint, 1024)
 	if err != nil {
 		panic(err)
 	}

backend/domain/plugin/entity/plugin.go

@@ -157,7 +157,6 @@ func NewDefaultPluginManifest() *PluginManifest {
 					Value: "Coze/1.0",
 				},
 			},
-			model.ParamInPath:  {},
 			model.ParamInQuery: {},
 		},
 	}

backend/domain/plugin/service/exec_tool.go

@@ -29,6 +29,7 @@ import (
 
 	"github.com/bytedance/sonic"
 	"github.com/getkin/kin-openapi/openapi3"
+	"github.com/tidwall/sjson"
 
 	einoCompose "github.com/cloudwego/eino/compose"
 
@@ -479,11 +480,6 @@ func (t *toolExecutor) execute(ctx context.Context, argumentsInJson string) (res
 		return nil, err
 	}
 
-	requestStr, err := sonic.MarshalString(args)
-	if err != nil {
-		return nil, err
-	}
-
 	httpReq, err := t.buildHTTPRequest(ctx, args)
 	if err != nil {
 		return nil, err
@@ -504,18 +500,29 @@ func (t *toolExecutor) execute(ctx context.Context, argumentsInJson string) (res
 	}
 
 	var reqBodyBytes []byte
-	if httpReq.Body != nil {
-		reqBodyBytes, err = io.ReadAll(httpReq.Body)
+	if httpReq.GetBody != nil {
+		reqBody, err := httpReq.GetBody()
 		if err != nil {
 			return nil, err
 		}
+		defer reqBody.Close()
+
+		reqBodyBytes, err = io.ReadAll(reqBody)
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	requestStr, err := genRequestString(httpReq, reqBodyBytes)
+	if err != nil {
+		return nil, err
 	}
 
 	restyReq := t.svc.httpCli.NewRequest()
 	restyReq.Header = httpReq.Header
 	restyReq.Method = httpReq.Method
 	restyReq.URL = httpReq.URL.String()
-	if len(reqBodyBytes) > 0 {
+	if reqBodyBytes != nil {
 		restyReq.SetBody(reqBodyBytes)
 	}
 	restyReq.SetContext(ctx)
@@ -559,6 +566,46 @@ func (t *toolExecutor) execute(ctx context.Context, argumentsInJson string) (res
 	}, nil
 }
 
+func genRequestString(req *http.Request, body []byte) (string, error) {
+	type Request struct {
+		Path   string            `json:"path"`
+		Header map[string]string `json:"header"`
+		Query  map[string]string `json:"query"`
+		Body   *[]byte           `json:"body"`
+	}
+
+	req_ := &Request{
+		Path:   req.URL.Path,
+		Header: map[string]string{},
+		Query:  map[string]string{},
+	}
+
+	if len(req.Header) > 0 {
+		for k, v := range req.Header {
+			req_.Header[k] = v[0]
+		}
+	}
+	if len(req.URL.Query()) > 0 {
+		for k, v := range req.URL.Query() {
+			req_.Query[k] = v[0]
+		}
+	}
+
+	requestStr, err := sonic.MarshalString(req_)
+	if err != nil {
+		return "", fmt.Errorf("[genRequestString] marshal failed, err=%s", err)
+	}
+
+	if body != nil {
+		requestStr, err = sjson.SetRaw(requestStr, "body", string(body))
+		if err != nil {
+			return "", fmt.Errorf("[genRequestString] set body failed, err=%s", err)
+		}
+	}
+
+	return requestStr, nil
+}
+
 func (t *toolExecutor) preprocessArgumentsInJson(ctx context.Context, argumentsInJson string) (args map[string]any, err error) {
 	args, err = t.prepareArguments(ctx, argumentsInJson)
 	if err != nil {
@@ -653,23 +700,13 @@ func (t *toolExecutor) buildHTTPRequest(ctx context.Context, argMaps map[string]
 		return nil, err
 	}
 
-	reqURL, err := locArgs.buildHTTPRequestURL(ctx, rawURL)
+	commonParams := t.plugin.Manifest.CommonParams
+
+	reqURL, err := locArgs.buildHTTPRequestURL(ctx, rawURL, commonParams)
 	if err != nil {
 		return nil, err
 	}
 
-	httpReq, err = http.NewRequestWithContext(ctx, tool.GetMethod(), reqURL.String(), nil)
-	if err != nil {
-		return nil, err
-	}
-
-	header, err := locArgs.buildHTTPRequestHeader(ctx)
-	if err != nil {
-		return nil, err
-	}
-
-	httpReq.Header = header
-
 	bodyArgs := map[string]any{}
 	for k, v := range argMaps {
 		if _, ok := locArgs.header[k]; ok {
@@ -684,13 +721,27 @@ func (t *toolExecutor) buildHTTPRequest(ctx context.Context, argMaps map[string]
 		bodyArgs[k] = v
 	}
 
-	bodyBytes, contentType, err := t.buildRequestBody(ctx, tool.Operation, bodyArgs)
+	commonBody := commonParams[model.ParamInBody]
+	bodyBytes, contentType, err := t.buildRequestBody(ctx, tool.Operation, bodyArgs, commonBody)
 	if err != nil {
 		return nil, err
 	}
+
+	httpReq, err = http.NewRequestWithContext(ctx, tool.GetMethod(), reqURL.String(), bytes.NewBuffer(bodyBytes))
+	if err != nil {
+		return nil, err
+	}
+
+	commonHeader := commonParams[model.ParamInHeader]
+	header, err := locArgs.buildHTTPRequestHeader(ctx, commonHeader)
+	if err != nil {
+		return nil, err
+	}
+
+	httpReq.Header = header
+
 	if len(bodyBytes) > 0 {
 		httpReq.Header.Set("Content-Type", contentType)
-		httpReq.Body = io.NopCloser(bytes.NewReader(bodyBytes))
 	}
 
 	return httpReq, nil
@@ -698,13 +749,6 @@ func (t *toolExecutor) buildHTTPRequest(ctx context.Context, argMaps map[string]
 
 func (t *toolExecutor) prepareArguments(_ context.Context, argumentsInJson string) (map[string]any, error) {
 	args := map[string]any{}
-	for loc, params := range t.plugin.Manifest.CommonParams {
-		for _, p := range params {
-			if loc != model.ParamInBody {
-				args[p.Name] = p.Value
-			}
-		}
-	}
 
 	decoder := sonic.ConfigDefault.NewDecoder(bytes.NewBufferString(argumentsInJson))
 	decoder.UseNumber()
@@ -1175,7 +1219,9 @@ type valueWithSchema struct {
 	paramSchema *openapi3.Parameter
 }
 
-func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string) (reqURL *url.URL, err error) {
+func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string,
+	commonParams map[model.HTTPParamLocation][]*common.CommonParamSchema) (reqURL *url.URL, err error) {
+
 	if len(l.path) > 0 {
 		for k, v := range l.path {
 			vStr, err := encoder.EncodeParameter(v.paramSchema, v.argValue)
@@ -1186,9 +1232,8 @@ func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string
 		}
 	}
 
-	encodeQuery := ""
+	query := url.Values{}
 	if len(l.query) > 0 {
-		query := url.Values{}
 		for k, val := range l.query {
 			switch v := val.argValue.(type) {
 			case []any:
@@ -1199,10 +1244,18 @@ func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string
 				query.Add(k, encoder.MustString(v))
 			}
 		}
-
-		encodeQuery = query.Encode()
 	}
 
+	commonQuery := commonParams[model.ParamInQuery]
+	for _, v := range commonQuery {
+		if _, ok := l.query[v.Name]; ok {
+			continue
+		}
+		query.Add(v.Name, v.Value)
+	}
+
+	encodeQuery := query.Encode()
+
 	reqURL, err = url.Parse(rawURL)
 	if err != nil {
 		return nil, err
@@ -1217,7 +1270,7 @@ func (l *locationArguments) buildHTTPRequestURL(_ context.Context, rawURL string
 	return reqURL, nil
 }
 
-func (l *locationArguments) buildHTTPRequestHeader(_ context.Context) (http.Header, error) {
+func (l *locationArguments) buildHTTPRequestHeader(_ context.Context, commonHeaders []*common.CommonParamSchema) (http.Header, error) {
 	header := http.Header{}
 	if len(l.header) > 0 {
 		for k, v := range l.header {
@@ -1232,44 +1285,64 @@ func (l *locationArguments) buildHTTPRequestHeader(_ context.Context) (http.Head
 		}
 	}
 
+	for _, h := range commonHeaders {
+		if header.Get(h.Name) != "" {
+			continue
+		}
+		header.Add(h.Name, h.Value)
+	}
+
 	return header, nil
 }
 
-func (t *toolExecutor) buildRequestBody(ctx context.Context, op *model.Openapi3Operation, bodyArgs map[string]any) (body []byte, contentType string, err error) {
+func (t *toolExecutor) buildRequestBody(ctx context.Context, op *model.Openapi3Operation, bodyArgs map[string]any,
+	commonBody []*common.CommonParamSchema) (body []byte, contentType string, err error) {
+
+	var bodyMap map[string]any
+
 	contentType, bodySchema := t.getReqBodySchema(op)
-	if bodySchema == nil || bodySchema.Value == nil {
-		return nil, "", nil
-	}
-
-	if len(bodySchema.Value.Properties) == 0 {
-		return nil, "", nil
-	}
-
-	bodyMap, err := t.injectRequestBodyDefaultValue(ctx, bodySchema.Value, bodyArgs)
-	if err != nil {
-		return nil, "", err
-	}
-
-	for paramName, prop := range bodySchema.Value.Properties {
-		value, ok := bodyMap[paramName]
-		if !ok {
-			continue
-		}
-
-		_value, err := encoder.TryFixValueType(paramName, prop, value)
+	if bodySchema != nil && len(bodySchema.Value.Properties) > 0 {
+		bodyMap, err = t.injectRequestBodyDefaultValue(ctx, bodySchema.Value, bodyArgs)
 		if err != nil {
 			return nil, "", err
 		}
 
-		bodyMap[paramName] = _value
+		for paramName, prop := range bodySchema.Value.Properties {
+			value, ok := bodyMap[paramName]
+			if !ok {
+				continue
+			}
+
+			_value, err := encoder.TryFixValueType(paramName, prop, value)
+			if err != nil {
+				return nil, "", err
+			}
+
+			bodyMap[paramName] = _value
+		}
+
+		body, err = encoder.EncodeBodyWithContentType(contentType, bodyMap)
+		if err != nil {
+			return nil, "", fmt.Errorf("[buildRequestBody] EncodeBodyWithContentType failed, err=%v", err)
+		}
 	}
 
-	reqBodyStr, err := encoder.EncodeBodyWithContentType(contentType, bodyMap)
-	if err != nil {
-		return nil, "", fmt.Errorf("[buildRequestBody] EncodeBodyWithContentType failed, err=%v", err)
+	commonBody_ := make([]*common.CommonParamSchema, 0, len(commonBody))
+	for _, v := range commonBody {
+		if _, ok := bodyMap[v.Name]; ok {
+			continue
+		}
+		commonBody_ = append(commonBody_, v)
 	}
 
-	return reqBodyStr, contentType, nil
+	for _, v := range commonBody_ {
+		body, err = sjson.SetRawBytes(body, v.Name, []byte(v.Value))
+		if err != nil {
+			return nil, "", fmt.Errorf("[buildRequestBody] SetRawBytes failed, err=%v", err)
+		}
+	}
+
+	return body, contentType, nil
 }
 
 func (t *toolExecutor) injectRequestBodyDefaultValue(ctx context.Context, sc *openapi3.Schema, vals map[string]any) (newVals map[string]any, err error) {
@@ -1327,7 +1400,7 @@ func (t *toolExecutor) injectRequestBodyDefaultValue(ctx context.Context, sc *op
 }
 
 func (t *toolExecutor) getReqBodySchema(op *model.Openapi3Operation) (string, *openapi3.SchemaRef) {
-	if op.RequestBody == nil || op.RequestBody.Value == nil || len(op.RequestBody.Value.Content) == 0 {
+	if op.RequestBody == nil || len(op.RequestBody.Value.Content) == 0 {
 		return "", nil
 	}
 

backend/domain/plugin/service/exec_tool_test.go

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2025 coze-dev Authors
+ *
+ * Licensed 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 service
+
+import (
+	"net/http"
+	"net/url"
+	"testing"
+
+	. "github.com/bytedance/mockey"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestGenRequestString(t *testing.T) {
+	PatchConvey("", t, func() {
+		requestStr, err := genRequestString(&http.Request{
+			Header: http.Header{
+				"Content-Type": []string{"application/json"},
+			},
+			Method: http.MethodPost,
+			URL:    &url.URL{Path: "/test"},
+		}, []byte(`{"a": 1}`))
+		assert.NoError(t, err)
+		assert.Equal(t, `{"header":{"Content-Type":["application/json"]},"query":null,"path":"/test","body":{"a": 1}}`, requestStr)
+	})
+
+	PatchConvey("", t, func() {
+		var body []byte
+		requestStr, err := genRequestString(&http.Request{
+			URL: &url.URL{Path: "/test"},
+		}, body)
+		assert.NoError(t, err)
+		assert.Equal(t, `{"header":null,"query":null,"path":"/test","body":null}`, requestStr)
+	})
+}

backend/domain/plugin/service/plugin_draft.go

@@ -46,6 +46,7 @@ import (
 
 func (p *pluginServiceImpl) CreateDraftPlugin(ctx context.Context, req *CreateDraftPluginRequest) (pluginID int64, err error) {
 	mf := entity.NewDefaultPluginManifest()
+	mf.CommonParams = map[model.HTTPParamLocation][]*plugin_develop_common.CommonParamSchema{}
 	mf.NameForHuman = req.Name
 	mf.NameForModel = req.Name
 	mf.DescriptionForHuman = req.Desc
@@ -65,11 +66,11 @@ func (p *pluginServiceImpl) CreateDraftPlugin(ctx context.Context, req *CreateDr
 			return 0, fmt.Errorf("invalid location '%s'", loc.String())
 		}
 		for _, param := range params {
-			mParams := mf.CommonParams[location]
-			mParams = append(mParams, &plugin_develop_common.CommonParamSchema{
-				Name:  param.Name,
-				Value: param.Value,
-			})
+			mf.CommonParams[location] = append(mf.CommonParams[location],
+				&plugin_develop_common.CommonParamSchema{
+					Name:  param.Name,
+					Value: param.Value,
+				})
 		}
 	}
 

backend/domain/plugin/service/plugin_oauth.go

@@ -194,7 +194,7 @@ func (p *pluginServiceImpl) getAccessTokenByAuthorizationCode(ctx context.Contex
 	meta := ci.Meta
 	info, exist, err := p.oauthRepo.GetAuthorizationCode(ctx, ci.Meta)
 	if err != nil {
-		return "", errorx.Wrapf(err, "GetAuthorizationCode failed, userID=%s, pluginID=%d, isDraft=%p",
+		return "", errorx.Wrapf(err, "GetAuthorizationCode failed, userID=%s, pluginID=%d, isDraft=%t",
 			meta.UserID, meta.PluginID, meta.IsDraft)
 	}
 	if !exist {

backend/go.mod

@@ -54,11 +54,12 @@ require github.com/alicebob/miniredis/v2 v2.34.0
 
 require (
 	github.com/DATA-DOG/go-sqlmock v1.5.2
+	github.com/aws/aws-sdk-go-v2/service/s3 v1.84.1
 	github.com/cloudwego/eino-ext/components/embedding/ark v0.0.0-20250522060253-ddb617598b09
 	github.com/cloudwego/eino-ext/components/embedding/ollama v0.0.0-20250728060543-79ec300857b8
 	github.com/cloudwego/eino-ext/components/embedding/openai v0.0.0-20250522060253-ddb617598b09
 	github.com/cloudwego/eino-ext/components/model/gemini v0.1.2
-	github.com/cloudwego/eino-ext/components/model/ollama v0.0.0-20250610035057-2c4e7c8488a5
+	github.com/cloudwego/eino-ext/components/model/ollama v0.1.0
 	github.com/cloudwego/eino-ext/components/model/qwen v0.0.0-20250612061754-5a3deb091dc5
 	github.com/dimchansky/utfbom v1.1.1
 	github.com/elastic/go-elasticsearch/v7 v7.17.10
@@ -84,7 +85,6 @@ require (
 	github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.37 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.5 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.18 // indirect
-	github.com/aws/aws-sdk-go-v2/service/s3 v1.84.1 // indirect
 	github.com/cloudwego/gopkg v0.1.4 // indirect
 	github.com/evanphx/json-patch v4.12.0+incompatible // indirect
 	github.com/extrame/ole2 v0.0.0-20160812065207-d69429661ad7 // indirect
@@ -111,10 +111,10 @@ require (
 require (
 	github.com/anthropics/anthropic-sdk-go v1.4.0 // indirect
 	github.com/avast/retry-go v3.0.0+incompatible // indirect
-	github.com/aws/aws-sdk-go-v2 v1.36.6 // indirect
+	github.com/aws/aws-sdk-go-v2 v1.36.6
 	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.11 // indirect
-	github.com/aws/aws-sdk-go-v2/config v1.29.1 // indirect
-	github.com/aws/aws-sdk-go-v2/credentials v1.17.54 // indirect
+	github.com/aws/aws-sdk-go-v2/config v1.29.1
+	github.com/aws/aws-sdk-go-v2/credentials v1.17.54
 	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.24 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.37 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.37 // indirect

backend/go.sum

@@ -822,12 +822,8 @@ github.com/avast/retry-go v3.0.0+incompatible h1:4SOWQ7Qs+oroOTQOYnAHqelpCO0biHS
 github.com/avast/retry-go v3.0.0+incompatible/go.mod h1:XtSnn+n/sHqQIpZ10K1qAevBhOOCWBLXXy3hyiqqBrY=
 github.com/aws/aws-sdk-go v1.40.45/go.mod h1:585smgzpB/KqRA+K3y/NL/oYRqQvpNJYvLm+LY1U59Q=
 github.com/aws/aws-sdk-go-v2 v1.9.1/go.mod h1:cK/D0BBs0b/oWPIcX/Z/obahJK1TT7IPVjy53i/mX/4=
-github.com/aws/aws-sdk-go-v2 v1.33.0 h1:Evgm4DI9imD81V0WwD+TN4DCwjUMdc94TrduMLbgZJs=
-github.com/aws/aws-sdk-go-v2 v1.33.0/go.mod h1:P5WJBrYqqbWVaOxgH0X/FYYD47/nooaPOZPlQdmiN2U=
 github.com/aws/aws-sdk-go-v2 v1.36.6 h1:zJqGjVbRdTPojeCGWn5IR5pbJwSQSBh5RWFTQcEQGdU=
 github.com/aws/aws-sdk-go-v2 v1.36.6/go.mod h1:EYrzvCCN9CMUTa5+6lf6MM4tq3Zjp8UhSGR/cBsjai0=
-github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3 h1:tW1/Rkad38LA15X4UQtjXZXNKsCgkshC3EbmcUmghTg=
-github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3/go.mod h1:UbnqO+zjqk3uIt9yCACHJ9IVNhyhOCnYk8yA19SAWrM=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.11 h1:12SpdwU8Djs+YGklkinSSlcrPyj3H4VifVsKf78KbwA=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.11/go.mod h1:dd+Lkp6YmMryke+qxW/VnKyhMBDTYP41Q2Bb+6gNZgY=
 github.com/aws/aws-sdk-go-v2/config v1.29.1 h1:JZhGawAyZ/EuJeBtbQYnaoftczcb2drR2Iq36Wgz4sQ=
@@ -836,12 +832,8 @@ github.com/aws/aws-sdk-go-v2/credentials v1.17.54 h1:4UmqeOqJPvdvASZWrKlhzpRahAu
 github.com/aws/aws-sdk-go-v2/credentials v1.17.54/go.mod h1:RTdfo0P0hbbTxIhmQrOsC/PquBZGabEPnCaxxKRPSnI=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.24 h1:5grmdTdMsovn9kPZPI23Hhvp0ZyNm5cRO+IZFIYiAfw=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.24/go.mod h1:zqi7TVKTswH3Ozq28PkmBmgzG1tona7mo9G2IJg4Cis=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.28 h1:igORFSiH3bfq4lxKFkTSYDhJEUCYo6C8VKiWJjYwQuQ=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.28/go.mod h1:3So8EA/aAYm36L7XIvCVwLa0s5N0P7o2b1oqnx/2R4g=
 github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.37 h1:osMWfm/sC/L4tvEdQ65Gri5ZZDCUpuYJZbTTDrsn4I0=
 github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.37/go.mod h1:ZV2/1fbjOPr4G4v38G3Ww5TBT4+hmsK45s/rxu1fGy0=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.28 h1:1mOW9zAUMhTSrMDssEHS/ajx8JcAj/IcftzcmNlmVLI=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.28/go.mod h1:kGlXVIWDfvt2Ox5zEaNglmq0hXPHgQFNMix33Tw22jA=
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.37 h1:v+X21AvTb2wZ+ycg1gx+orkB/9U6L7AOp93R7qYxsxM=
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.37/go.mod h1:G0uM1kyssELxmJ2VZEfG0q2npObR3BAkF3c1VsfVnfs=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1 h1:VaRN3TlFdd6KxX1x3ILT5ynH6HvKgqdiXoTxAF4HQcQ=
@@ -849,14 +841,10 @@ github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1/go.mod h1:FbtygfRFze9usAadmnGJN
 github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.37 h1:XTZZ0I3SZUHAtBLBU6395ad+VOblE0DwQP6MuaNeics=
 github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.37/go.mod h1:Pi6ksbniAWVwu2S8pEzcYPyhUkAcLaufxN7PfAUQjBk=
 github.com/aws/aws-sdk-go-v2/service/cloudwatch v1.8.1/go.mod h1:CM+19rL1+4dFWnOQKwDc7H1KwXTz+h61oUSHyhV0b3o=
-github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.1 h1:iXtILhvDxB6kPvEXgsDhGaZCSC6LQET5ZHSdJozeI0Y=
-github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.1/go.mod h1:9nu0fVANtYiAePIBh2/pFUSwtJ402hLnp854CNoDOeE=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.4 h1:CXV68E2dNqhuynZJPB80bhPQwAKqBWVer887figW6Jc=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.4/go.mod h1:/xFi9KtvBXP97ppCz1TAEvU1Uf66qvid89rbem3wCzQ=
 github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.5 h1:M5/B8JUaCI8+9QD+u3S/f4YHpvqE9RpSkV3rf0Iks2w=
 github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.5/go.mod h1:Bktzci1bwdbpuLiu3AOksiNPMl/LLKmX1TWmqp2xbvs=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.9 h1:TQmKDyETFGiXVhZfQ/I0cCFziqqX58pi4tKJGYGFSz0=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.9/go.mod h1:HVLPK2iHQBUx7HfZeOQSEu3v2ubZaAY2YPbAm5/WUyY=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.18 h1:vvbXsA2TVO80/KT7ZqCbx934dt6PY+vQ8hZpUZ/cpYg=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.18/go.mod h1:m2JJHledjBGNMsLOF1g9gbAxprzq3KjC8e4lxtn+eWg=
 github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.18 h1:OS2e0SKqsU2LiJPqL8u9x41tKc6MMEHrWjLVLn3oysg=
@@ -870,8 +858,6 @@ github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.10/go.mod h1:Fzsj6lZEb8AkTE5S
 github.com/aws/aws-sdk-go-v2/service/sts v1.33.9 h1:BRVDbewN6VZcwr+FBOszDKvYeXY1kJ+GGMCcpghlw0U=
 github.com/aws/aws-sdk-go-v2/service/sts v1.33.9/go.mod h1:f6vjfZER1M17Fokn0IzssOTMT2N8ZSq+7jnNF0tArvw=
 github.com/aws/smithy-go v1.8.0/go.mod h1:SObp3lf9smib00L/v3U2eAKG8FyQ7iLrJnQiAmR5n+E=
-github.com/aws/smithy-go v1.22.1 h1:/HPHZQ0g7f4eUeK6HKglFz8uwVfZKgoI25rb/J+dnro=
-github.com/aws/smithy-go v1.22.1/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
 github.com/aws/smithy-go v1.22.4 h1:uqXzVZNuNexwc/xrh6Tb56u89WDlJY6HS+KC0S4QSjw=
 github.com/aws/smithy-go v1.22.4/go.mod h1:t1ufH5HMublsJYulve2RKmHDC15xu1f26kHCp/HgceI=
 github.com/aymerick/raymond v2.0.3-0.20180322193309-b565731e1464+incompatible/go.mod h1:osfaiScAUVup+UC9Nfq76eWqDhXlp+4UYaA8uhTBO6g=
@@ -956,6 +942,8 @@ github.com/cloudwego/eino-ext/components/model/gemini v0.1.2 h1:bt9xftOQhP0Nuh1P
 github.com/cloudwego/eino-ext/components/model/gemini v0.1.2/go.mod h1:1tv89uZ9hR/4AyQ+9yxFWLn52GaJDKtPXdEY7WZdyZc=
 github.com/cloudwego/eino-ext/components/model/ollama v0.0.0-20250610035057-2c4e7c8488a5 h1:GkAAQHQkb1cOTwm6uRokj4lM//wrt/3AkMwTxyFJUg4=
 github.com/cloudwego/eino-ext/components/model/ollama v0.0.0-20250610035057-2c4e7c8488a5/go.mod h1:giNUFqA+V7xrm/EDvH7JFnDqoWI+e2m1SVAnReU+Fd8=
+github.com/cloudwego/eino-ext/components/model/ollama v0.1.0 h1:FW067iMfg3EZbUaZIo8v3i2ILBAZDzY23/9pbprvE0M=
+github.com/cloudwego/eino-ext/components/model/ollama v0.1.0/go.mod h1:+qA5kkUCM0mIrXGSNzxLcjxh6K1AghPNigtEyyMdkOc=
 github.com/cloudwego/eino-ext/components/model/openai v0.0.0-20250715055739-0d0e28441a2f h1:ovS39vuN2JW+C/O9jtEmOUuLEY4fw0yYh8//yhMfJNM=
 github.com/cloudwego/eino-ext/components/model/openai v0.0.0-20250715055739-0d0e28441a2f/go.mod h1:2mFQQnlhJrNgbW6YX1MOUUfXkGSbTz9Ylx37fbR0xBo=
 github.com/cloudwego/eino-ext/components/model/qwen v0.0.0-20250612061754-5a3deb091dc5 h1:4zAZiNo/PkeVc0Gw8YLpzpbR8zDzccL7H5PLqTuGhv4=

backend/infra/impl/cache/redis/redis.go

@@ -27,9 +27,11 @@ type Client = redis.Client
 
 func New() *redis.Client {
 	addr := os.Getenv("REDIS_ADDR")
+        password := os.Getenv("REDIS_PASSWORD")
 	rdb := redis.NewClient(&redis.Options{
 		Addr: addr, // Redis地址
 		DB:   0,    // 默认数据库
+		Password: password,
 		// 连接池配置
 		PoolSize:        100,             // 最大连接数（建议设置为CPU核心数*10）
 		MinIdleConns:    10,              // 最小空闲连接

backend/infra/impl/document/ocr/veocr/ve_ocr.go

@@ -24,12 +24,12 @@ import (
 	"net/url"
 	"strconv"
 
-	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
-	"github.com/coze-dev/coze-studio/backend/types/errno"
 	"github.com/volcengine/volc-sdk-golang/service/visual"
 	"github.com/volcengine/volcengine-go-sdk/service/arkruntime/model"
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/document/ocr"
+	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
+	"github.com/coze-dev/coze-studio/backend/types/errno"
 )
 
 type Config struct {

backend/infra/impl/document/parser/builtin/py_parser_protocol.go

@@ -249,6 +249,11 @@ func formatTablesInDocument(input []*schema.Document) (output []*schema.Document
 				values = append(values, col.Name)
 			}
 			write(values)
+			if colOnly, err := document.GetDocumentColumnsOnly(doc); err != nil {
+				return nil, err
+			} else if colOnly {
+				break
+			}
 		}
 
 		data, err := document.GetDocumentColumnData(doc)

backend/infra/impl/embedding/ark/ark.go

@@ -25,12 +25,12 @@ import (
 
 	"github.com/cloudwego/eino-ext/components/embedding/ark"
 	"github.com/cloudwego/eino/components/embedding"
-	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
-	"github.com/coze-dev/coze-studio/backend/types/errno"
 	"github.com/volcengine/volcengine-go-sdk/service/arkruntime/model"
 
 	contract "github.com/coze-dev/coze-studio/backend/infra/contract/embedding"
+	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/pkg/lang/slices"
+	"github.com/coze-dev/coze-studio/backend/types/errno"
 )
 
 func NewArkEmbedder(ctx context.Context, config *ark.EmbeddingConfig, dimensions int64) (contract.Embedder, error) {

backend/infra/impl/embedding/http/http.go

@@ -22,7 +22,6 @@ import (
 	"encoding/json"
 	"io"
 	"net/http"
-	"strconv"
 	"time"
 
 	opt "github.com/cloudwego/eino/components/embedding"
@@ -30,10 +29,7 @@ import (
 	"github.com/coze-dev/coze-studio/backend/infra/contract/embedding"
 )
 
-const (
-	pathDim   = "/dimension"
-	pathEmbed = "/embedding"
-)
+const pathEmbed = "/embedding"
 
 type embedReq struct {
 	Texts      []string `json:"texts"`
@@ -45,32 +41,12 @@ type embedResp struct {
 	Sparse []map[int]float64 `json:"sparse"`
 }
 
-func NewEmbedding(addr string) (embedding.Embedder, error) {
+func NewEmbedding(addr string, dims int64) (embedding.Embedder, error) {
 	cli := &http.Client{Timeout: time.Second * 30}
-	req, err := http.NewRequest(http.MethodGet, addr+pathDim, nil)
-	if err != nil {
-		return nil, err
-	}
-
-	resp, err := cli.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer resp.Body.Close()
-	b, err := io.ReadAll(resp.Body)
-	if err != nil {
-		return nil, err
-	}
-
-	dim, err := strconv.ParseInt(string(b), 10, 64)
-	if err != nil {
-		return nil, err
-	}
-
 	return &embedder{
 		cli:  cli,
 		addr: addr,
-		dim:  dim,
+		dim:  dims,
 	}, nil
 }
 

backend/infra/impl/embedding/http/http_test.go

@@ -31,7 +31,7 @@ func TestHTTPEmbedding(t *testing.T) {
 	}
 
 	ctx := context.Background()
-	emb, err := NewEmbedding("http://127.0.0.1:6543")
+	emb, err := NewEmbedding("http://127.0.0.1:6543", 1024)
 	assert.NoError(t, err)
 	texts := []string{
 		"hello",

backend/infra/impl/embedding/wrap/ollama.go

@@ -20,6 +20,7 @@ import (
 	"context"
 
 	"github.com/cloudwego/eino-ext/components/embedding/ollama"
+
 	contract "github.com/coze-dev/coze-studio/backend/infra/contract/embedding"
 )
 

backend/infra/impl/storage/minio/minio.go

@@ -23,9 +23,7 @@ import (
 	"io"
 	"log"
 	"math/rand"
-	"net"
 	"net/url"
-	"os"
 	"time"
 
 	"github.com/minio/minio-go/v7"
@@ -33,6 +31,7 @@ import (
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/imagex"
 	"github.com/coze-dev/coze-studio/backend/infra/contract/storage"
+	"github.com/coze-dev/coze-studio/backend/infra/impl/storage/proxy"
 	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/types/consts"
@@ -211,27 +210,9 @@ func (m *minioClient) GetObjectUrl(ctx context.Context, objectKey string, opts .
 	}
 
 	// logs.CtxDebugf(ctx, "[GetObjectUrl] origin presignedURL.String = %s", presignedURL.String())
-
-	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
-	if len(proxyPort) > 0 {
-		currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
-		if !ok {
-			return presignedURL.String(), nil
-		}
-
-		currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
-		if !ok {
-			return presignedURL.String(), nil
-		}
-
-		host, _, err := net.SplitHostPort(currentHost)
-		if err != nil {
-			host = currentHost
-		}
-		minioProxyHost := host + proxyPort
-		presignedURL.Host = minioProxyHost
-		presignedURL.Scheme = currentScheme
-		// logs.CtxDebugf(ctx, "[GetObjectUrl] reset presignedURL.String = %s", presignedURL.String())
+	ok, proxyURL := proxy.CheckIfNeedReplaceHost(ctx, presignedURL.String())
+	if ok {
+		return proxyURL, nil
 	}
 
 	return presignedURL.String(), nil
@@ -265,7 +246,6 @@ func (m *minioClient) GetUploadAuth(ctx context.Context, opt ...imagex.UploadAut
 }
 
 func (m *minioClient) GetResourceURL(ctx context.Context, uri string, opts ...imagex.GetResourceOpt) (*imagex.ResourceURL, error) {
-
 	url, err := m.GetObjectUrl(ctx, uri)
 	if err != nil {
 		return nil, err
@@ -273,11 +253,12 @@ func (m *minioClient) GetResourceURL(ctx context.Context, uri string, opts ...im
 	return &imagex.ResourceURL{
 		URL: url,
 	}, nil
-
 }
+
 func (m *minioClient) Upload(ctx context.Context, data []byte, opts ...imagex.UploadAuthOpt) (*imagex.UploadResult, error) {
 	return nil, nil
 }
+
 func (m *minioClient) GetUploadAuthWithExpire(ctx context.Context, expire time.Duration, opt ...imagex.UploadAuthOpt) (*imagex.SecurityToken, error) {
 	return nil, nil
 }

backend/infra/impl/storage/proxy/proxy.go

@@ -0,0 +1,63 @@
+/*
+ * Copyright 2025 coze-dev Authors
+ *
+ * Licensed 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 (
+	"context"
+	"net"
+	"net/url"
+	"os"
+
+	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
+	"github.com/coze-dev/coze-studio/backend/pkg/logs"
+	"github.com/coze-dev/coze-studio/backend/types/consts"
+)
+
+func CheckIfNeedReplaceHost(ctx context.Context, originURLStr string) (ok bool, proxyURL string) {
+	// url parse
+	originURL, err := url.Parse(originURLStr)
+	if err != nil {
+		logs.CtxWarnf(ctx, "[CheckIfNeedReplaceHost] url parse failed, err: %v", err)
+		return false, ""
+	}
+
+	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
+	if proxyPort == "" {
+		return false, ""
+	}
+
+	currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
+	if !ok {
+		return false, ""
+	}
+
+	currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
+	if !ok {
+		return false, ""
+	}
+
+	host, _, err := net.SplitHostPort(currentHost)
+	if err != nil {
+		host = currentHost
+	}
+
+	minioProxyHost := host + proxyPort
+	originURL.Host = minioProxyHost
+	originURL.Scheme = currentScheme
+	logs.CtxDebugf(ctx, "[CheckIfNeedReplaceHost] reset originURL.String = %s", originURL.String())
+	return true, originURL.String()
+}

backend/infra/impl/storage/s3/s3.go

@@ -21,9 +21,6 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"net"
-	"net/url"
-	"os"
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
@@ -33,6 +30,7 @@ import (
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/imagex"
 	"github.com/coze-dev/coze-studio/backend/infra/contract/storage"
+	"github.com/coze-dev/coze-studio/backend/infra/impl/storage/proxy"
 	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/pkg/logs"
@@ -219,34 +217,9 @@ func (t *s3Client) GetObjectUrl(ctx context.Context, objectKey string, opts ...s
 		return "", fmt.Errorf("get object presigned url failed: %v", err)
 	}
 
-	// url parse
-	url, err := url.Parse(req.URL)
-	if err != nil {
-		logs.CtxWarnf(ctx, "[GetObjectUrl] url parse failed, err: %v", err)
-		return req.URL, nil
-	}
-
-	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
-	if len(proxyPort) > 0 {
-		currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
-		if !ok {
-			return req.URL, nil
-		}
-
-		currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
-		if !ok {
-			return req.URL, nil
-		}
-
-		host, _, err := net.SplitHostPort(currentHost)
-		if err != nil {
-			host = currentHost
-		}
-		minioProxyHost := host + proxyPort
-		url.Host = minioProxyHost
-		url.Scheme = currentScheme
-		logs.CtxInfof(ctx, "[GetObjectUrl] reset ORG.URL = %s  TOS.URL = %s", req.URL, url.String())
-		return url.String(), nil
+	ok, proxyURL := proxy.CheckIfNeedReplaceHost(ctx, req.URL)
+	if ok {
+		return proxyURL, nil
 	}
 
 	return req.URL, nil
@@ -258,7 +231,6 @@ func (i *s3Client) GetUploadHost(ctx context.Context) string {
 		return ""
 	}
 	return currentHost + consts.ApplyUploadActionURI
-
 }
 
 func (t *s3Client) GetServerID() string {

backend/infra/impl/storage/tos/tos.go

@@ -21,10 +21,7 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"net"
 	"net/http"
-	"net/url"
-	"os"
 	"time"
 
 	"github.com/volcengine/ve-tos-golang-sdk/v2/tos"
@@ -32,6 +29,7 @@ import (
 
 	"github.com/coze-dev/coze-studio/backend/infra/contract/imagex"
 	"github.com/coze-dev/coze-studio/backend/infra/contract/storage"
+	"github.com/coze-dev/coze-studio/backend/infra/impl/storage/proxy"
 	"github.com/coze-dev/coze-studio/backend/pkg/ctxcache"
 	"github.com/coze-dev/coze-studio/backend/pkg/errorx"
 	"github.com/coze-dev/coze-studio/backend/pkg/lang/conv"
@@ -213,34 +211,9 @@ func (t *tosClient) GetObjectUrl(ctx context.Context, objectKey string, opts ...
 		return "", err
 	}
 
-	// url parse
-	url, err := url.Parse(output.SignedUrl)
-	if err != nil {
-		logs.CtxWarnf(ctx, "[GetObjectUrl] url parse failed, err: %v", err)
-		return output.SignedUrl, nil
-	}
-
-	proxyPort := os.Getenv(consts.MinIOProxyEndpoint) // :8889
-	if len(proxyPort) > 0 {
-		currentHost, ok := ctxcache.Get[string](ctx, consts.HostKeyInCtx)
-		if !ok {
-			return output.SignedUrl, nil
-		}
-
-		currentScheme, ok := ctxcache.Get[string](ctx, consts.RequestSchemeKeyInCtx)
-		if !ok {
-			return output.SignedUrl, nil
-		}
-
-		host, _, err := net.SplitHostPort(currentHost)
-		if err != nil {
-			host = currentHost
-		}
-		minioProxyHost := host + proxyPort
-		url.Host = minioProxyHost
-		url.Scheme = currentScheme
-		// logs.CtxDebugf(ctx, "[GetObjectUrl] reset \n ORG.URL = %s \n TOS.URL = %s", output.SignedUrl, url.String())
-		return url.String(), nil
+	ok, proxyURL := proxy.CheckIfNeedReplaceHost(ctx, output.SignedUrl)
+	if ok {
+		return proxyURL, nil
 	}
 
 	return output.SignedUrl, nil

backend/main.go

@@ -74,9 +74,10 @@ func startHttpServer() {
 		server.WithMaxRequestBodySize(int(maxSize)),
 	}
 
-	useSSL := getEnv("USE_SSL", "0")
+	useSSL := getEnv(consts.UseSSL, "0")
 	if useSSL == "1" {
-		cert, err := tls.LoadX509KeyPair("cert.pem", "key.pem")
+		cert, err := tls.LoadX509KeyPair(getEnv(consts.SSLCertFile, ""),
+			getEnv(consts.SSLKeyFile, ""))
 		if err != nil {
 			fmt.Println(err.Error())
 		}
@@ -193,10 +194,12 @@ func asyncStartMinioProxyServer(ctx context.Context) {
 			originDirector(req)
 			req.Host = req.URL.Host
 		}
-		useSSL := getEnv("USE_SSL", "0")
+		useSSL := getEnv(consts.UseSSL, "0")
 		if useSSL == "1" {
 			logs.Infof("Minio proxy server is listening on %s with SSL", minioProxyEndpoint)
-			err := http.ListenAndServeTLS(minioProxyEndpoint, "cert.pem", "key.pem", proxy)
+			err := http.ListenAndServeTLS(minioProxyEndpoint,
+				getEnv(consts.SSLCertFile, ""),
+				getEnv(consts.SSLKeyFile, ""), proxy)
 			if err != nil {
 				log.Fatal(err)
 			}

backend/types/consts/consts.go

@@ -81,6 +81,10 @@ const (
 	CodeRunnerNodeModulesDir = "CODE_RUNNER_NODE_MODULES_DIR"
 	CodeRunnerTimeoutSeconds = "CODE_RUNNER_TIMEOUT_SECONDS"
 	CodeRunnerMemoryLimitMB  = "CODE_RUNNER_MEMORY_LIMIT_MB"
+
+	UseSSL      = "USE_SSL"
+	SSLCertFile = "SSL_CERT_FILE"
+	SSLKeyFile  = "SSL_KEY_FILE"
 )
 
 const (

common/config/subspaces/default/pnpm-lock.yaml

@@ -19030,8 +19030,8 @@ importers:
         specifier: workspace:*
         version: link:../../../arch/i18n
       '@coze/chat-sdk':
-        specifier: 0.1.11-beta.17
-        version: 0.1.11-beta.17(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0)
+        specifier: 0.1.11-beta.19
+        version: 0.1.11-beta.19(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0)
       react:
         specifier: 18.2.0
         version: 18.2.0
@@ -26106,8 +26106,8 @@ packages:
       - utf-8-validate
     dev: false
 
-  /@coze/chat-sdk@0.1.11-beta.17(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0):
-    resolution: {integrity: sha512-nrev9w8IeW9mPqVhl4nT/8Z6fnaja4RlNqXj5e+MPjJugPTOw1brXuHTN2sVKUuFEsc5qse0U531qKJDg34zkA==}
+  /@coze/chat-sdk@0.1.11-beta.19(@types/react@18.2.37)(axios@1.10.0)(debug@4.3.3)(lodash-es@4.17.21)(react-dom@18.2.0)(react@18.2.0):
+    resolution: {integrity: sha512-DRZ1yuWhYiiOZfbAiD9ifCVA7TiC8Wia4SfkJs5O8kCgbujF2nJrekEWUD6nzt9ivY8oT6Ve/eXfq/jK4CSq6g==}
     requiresBuild: true
     peerDependencies:
       axios: ^1.7.1
@@ -26133,6 +26133,7 @@ packages:
       micromark-extension-misc-radio-list-item: 2.1.0
       react: 18.2.0
       react-dom: 18.2.0(react@18.2.0)
+      xss: 1.0.15
       zustand: 4.5.7(@types/react@18.2.37)(immer@10.1.1)(react@18.2.0)
     transitivePeerDependencies:
       - '@types/react'
@@ -35368,7 +35369,7 @@ packages:
     resolution: {integrity: sha512-b3nLFGaGkJ9rzOcuXRfHkZMdjsawuDD0ENL9fzTophtBg8FJHSGbH7daXkEpcwy3v7Xol3pAvsmlYyFhR4pqJw==}
     dependencies:
       '@types/node': 18.18.9
-      '@types/unist': 2.0.11
+      '@types/unist': 3.0.3
       '@types/vfile-message': 2.0.0
     dev: true
 
@@ -38170,7 +38171,7 @@ packages:
       path-case: 3.0.4
       sentence-case: 3.0.4
       snake-case: 3.0.4
-      tslib: 2.6.3
+      tslib: 2.8.1
 
   /character-entities-html4@1.1.4:
     resolution: {integrity: sha512-HRcDxZuZqMx3/a+qrzxdBKBPUpxWEq9xw2OPZ3a/174ihfrQKVsFhqtthBInFy1zZ9GgZyFXOatNujm8M+El3g==}
@@ -49817,7 +49818,7 @@ packages:
     dependencies:
       '@types/react': 18.2.37
       react: 18.2.0
-      tslib: 2.6.3
+      tslib: 2.8.1
     dev: false
 
   /react-virtualized-auto-sizer@1.0.26(react-dom@18.2.0)(react@18.2.0):
@@ -53487,6 +53488,7 @@ packages:
 
   /tslib@2.6.3:
     resolution: {integrity: sha512-xNvxJEOUiWPGhUuUdQgAJPKOOJfGnIyKySOc09XkKsgdUV/3E2zvwZYdejjmRgPCgcym1juLH3226yA7sEFJKQ==}
+    dev: false
 
   /tslib@2.8.1:
     resolution: {integrity: sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==}
@@ -55619,7 +55621,7 @@ packages:
       '@types/ws': 8.18.1
       ansi-html-community: 0.0.8
       bonjour-service: 1.3.0
-      chokidar: 3.5.3
+      chokidar: 3.6.0
       colorette: 2.0.19
       compression: 1.8.0
       connect-history-api-fallback: 2.0.0

docker/.env.example

@@ -4,6 +4,9 @@ export LOG_LEVEL="debug"
 export MAX_REQUEST_BODY_SIZE=1073741824
 export SERVER_HOST="localhost${LISTEN_ADDR}"
 export MINIO_PROXY_ENDPOINT=":8889"
+export USE_SSL="0"
+export SSL_CERT_FILE=""
+export SSL_KEY_FILE=""
 
 # MySQL
 export MYSQL_ROOT_PASSWORD=root
@@ -20,6 +23,7 @@ export REDIS_AOF_ENABLED=no
 export REDIS_IO_THREADS=4
 export ALLOW_EMPTY_PASSWORD=yes
 export REDIS_ADDR="localhost:6379"
+export REDIS_PASSWORD=""
 
 # This Upload component used in Agent / workflow File/Image With LLM  , support the component of imagex / storage
 # default: storage, use the settings of storage component
@@ -115,6 +119,7 @@ export OLLAMA_EMBEDDING_DIMS=""
 
 # http embedding
 export HTTP_EMBEDDING_ADDR="http://127.0.0.1:6543"
+export HTTP_EMBEDDING_DIMS=1024
 
 # Settings for OCR
 # If you want to use the OCR-related functions in the knowledge base feature，You need to set up the OCR configuration.

docker/docker-compose.yml

@@ -230,7 +230,7 @@ services:
           cp /opt/bitnami/elasticsearch/analysis-smartcn.zip /tmp/analysis-smartcn.zip 
 
           elasticsearch-plugin install file:///tmp/analysis-smartcn.zip
-          if [[ "$?" != "0" ]]; then
+          if [[ "$$?" != "0" ]]; then
             echo 'Plugin installation failed, exiting operation';
             rm -rf /opt/bitnami/elasticsearch/plugins/analysis-smartcn
             exit 1;
@@ -481,7 +481,7 @@ services:
       - -c
       - |
         set -ex
-        for i in $(seq 1 60); do
+        for i in $$(seq 1 60); do
           DB_HOST="$${MYSQL_HOST}"
           if [ "$${MYSQL_HOST}" = "localhost" ] || [ "$${MYSQL_HOST}" = "127.0.0.1" ]; then
             DB_HOST="mysql"

frontend/packages/studio/open-platform/open-chat/package.json

@@ -21,7 +21,7 @@
   },
   "dependencies": {
     "@coze-arch/i18n": "workspace:*",
-    "@coze/chat-sdk": "0.1.11-beta.17",
+    "@coze/chat-sdk": "0.1.11-beta.19",
     "react": "~18.2.0"
   },
   "devDependencies": {

helm/charts/opencoze/templates/NOTES.txt

@@ -5,18 +5,22 @@
   http{{ if $.Values.ingress.tls }}s{{ end }}://{{ $host.host }}{{ .path }}
   {{- end }}
 {{- end }}
-{{- else if contains "NodePort" .Values.service.type }}
+{{- else if contains "NodePort" .Values.cozeServer.service.type }}
   export NODE_PORT=$(kubectl get --namespace {{ .Release.Namespace }} -o jsonpath="{.spec.ports[0].nodePort}" services {{ include "opencoze.fullname" . }})
   export NODE_IP=$(kubectl get nodes --namespace {{ .Release.Namespace }} -o jsonpath="{.items[0].status.addresses[0].address}")
   echo http://$NODE_IP:$NODE_PORT
-{{- else if contains "LoadBalancer" .Values.service.type }}
+{{- else if contains "LoadBalancer" .Values.cozeServer.service.type }}
      NOTE: It may take a few minutes for the LoadBalancer IP to be available.
            You can watch its status by running 'kubectl get --namespace {{ .Release.Namespace }} svc -w {{ include "opencoze.fullname" . }}'
   export SERVICE_IP=$(kubectl get svc --namespace {{ .Release.Namespace }} {{ include "opencoze.fullname" . }} --template "{{"{{ range (index .status.loadBalancer.ingress 0) }}{{.}}{{ end }}"}}")
-  echo http://$SERVICE_IP:{{ .Values.service.port }}
-{{- else if contains "ClusterIP" .Values.service.type }}
+  {{- range .Values.cozeServer.service.ports }}}
+  {{- if eq .name "http" }}
+  echo http://$SERVICE_IP:{{ .port }}
+  {{- end}}
+  {{- end}}
+{{- else if contains "ClusterIP" .Values.cozeServer.service.type }}
   export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "app.kubernetes.io/name={{ include "opencoze.name" . }},app.kubernetes.io/instance={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}")
   export CONTAINER_PORT=$(kubectl get pod --namespace {{ .Release.Namespace }} $POD_NAME -o jsonpath="{.spec.containers[0].ports[0].containerPort}")
-  echo "Visit http://127.0.0.1:8080 to use your application"
+  echo "Visit http://127.0.0.1:{{ .Values.service.port}} to use your application"
   kubectl --namespace {{ .Release.Namespace }} port-forward $POD_NAME 8080:$CONTAINER_PORT
 {{- end }}

helm/charts/opencoze/templates/elasticsearch-statefulset.yaml

@@ -81,7 +81,9 @@ spec:
       name: es-data
     spec:
       accessModes: [ "ReadWriteOnce" ]
+    {{- if .Values.elasticsearch.persistence.storageClassName }}
       storageClassName: {{ .Values.elasticsearch.persistence.storageClassName | quote }}
+    {{- end }}
       resources:
         requests:
           storage: {{ .Values.elasticsearch.persistence.size | quote }}

helm/charts/opencoze/templates/etcd-statefulset.yaml

@@ -53,7 +53,9 @@ spec:
         name: etcd-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.etcd.persistence.storageClassName }}
         storageClassName: {{ .Values.etcd.persistence.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.etcd.persistence.size | quote }}

helm/charts/opencoze/templates/milvus-statefulset.yaml

@@ -25,7 +25,14 @@ spec:
           securityContext:
             runAsUser: 0
           image: "{{ .Values.milvus.image.repository }}:{{ .Values.milvus.image.tag }}"
-          command: ["milvus", "run", "standalone"]
+          command:
+            - bash
+            - -c
+            - |
+              # Set proper permissions for data directories
+              chown -R root:root /var/lib/milvus
+              chmod g+s /var/lib/milvus
+              exec milvus run standalone
           env:
             - name: ETCD_ENDPOINTS
               value: "{{ include "opencoze.fullname" . }}-etcd:2379"
@@ -70,7 +77,9 @@ spec:
         name: milvus-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.milvus.persistence.storageClassName }}
         storageClassName: {{ .Values.milvus.persistence.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.milvus.persistence.size | quote }}

helm/charts/opencoze/templates/minio-statefulset.yaml

@@ -58,7 +58,9 @@ spec:
         name: minio-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.minio.persistence.storageClassName }}
         storageClassName: {{ .Values.minio.persistence.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.minio.persistence.size | quote }}

helm/charts/opencoze/templates/mysql-statefulset.yaml

@@ -55,7 +55,9 @@ spec:
         name: mysql-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.mysql.persistence.storageClassName }}
         storageClassName: {{ .Values.mysql.persistence.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.mysql.persistence.size | quote }}

helm/charts/opencoze/templates/redis-statefulset.yaml

@@ -42,7 +42,9 @@ spec:
         name: redis-data
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.redis.persistence.storageClassName }}
         storageClassName: {{ .Values.redis.persistence.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.redis.persistence.size | quote }}

helm/charts/opencoze/templates/rocketmq-broker-configmap.yaml

@@ -1,3 +1,4 @@
+{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") }}
 apiVersion: v1
 kind: ConfigMap
 metadata:
@@ -13,4 +14,5 @@ data:
     fileReservedTime = 48
     brokerRole = ASYNC_MASTER
     flushDiskType = ASYNC_FLUSH
-    brokerIP1 = __POD_IP__
+    brokerIP1 = __POD_IP__
+{{- end}}

helm/charts/opencoze/templates/rocketmq-broker-service.yaml

@@ -1,4 +1,4 @@
-{{- if .Values.rocketmq.enabled }}
+{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
 apiVersion: v1
 kind: Service
 metadata:

helm/charts/opencoze/templates/rocketmq-broker-statefulset.yaml

@@ -1,4 +1,4 @@
-{{- if .Values.rocketmq.enabled }}
+{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
 apiVersion: apps/v1
 kind: StatefulSet
 metadata:
@@ -111,7 +111,9 @@ spec:
         name: broker-store
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.rocketmq.broker.persistence.store.storageClassName }}
         storageClassName: {{ .Values.rocketmq.broker.persistence.store.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.broker.persistence.store.size | quote }}
@@ -119,7 +121,9 @@ spec:
         name: broker-logs
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.rocketmq.broker.persistence.logs.storageClassName }}
         storageClassName: {{ .Values.rocketmq.broker.persistence.logs.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.broker.persistence.logs.size | quote }}

helm/charts/opencoze/templates/rocketmq-namesrv-service.yaml

@@ -1,4 +1,4 @@
-{{- if .Values.rocketmq.enabled }}
+{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
 apiVersion: v1
 kind: Service
 metadata:

helm/charts/opencoze/templates/rocketmq-namesrv-statefulset.yaml

@@ -1,4 +1,4 @@
-{{- if .Values.rocketmq.enabled }}
+{{- if and (eq (lower (default "rmq" .Values.cozeServer.env.COZE_MQ_TYPE)) "rmq") .Values.rocketmq.enabled }}
 apiVersion: apps/v1
 kind: StatefulSet
 metadata:
@@ -56,7 +56,9 @@ spec:
         name: namesrv-store
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.rocketmq.namesrv.persistence.store.storageClassName }}
         storageClassName: {{ .Values.rocketmq.namesrv.persistence.store.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.namesrv.persistence.store.size | quote }}
@@ -64,7 +66,9 @@ spec:
         name: namesrv-logs
       spec:
         accessModes: [ "ReadWriteOnce" ]
+      {{- if .Values.rocketmq.namesrv.persistence.logs.storageClassName }}
         storageClassName: {{ .Values.rocketmq.namesrv.persistence.logs.storageClassName | quote }}
+      {{- end }}
         resources:
           requests:
             storage: {{ .Values.rocketmq.namesrv.persistence.logs.size | quote }}

helm/charts/opencoze/values-local.yaml

@@ -1,45 +0,0 @@
-mysql:
-  persistence:
-    storageClassName: "hostpath"
-
-redis:
-  persistence:
-    storageClassName: "hostpath"
-
-# -- coze-server configuration
-cozeServer:
-  env:
-    MINIO_ENDPOINT: "localhost:9000"
-
-
-rocketmq:
-  namesrv:
-    persistence:
-      store:
-        storageClassName: "hostpath"
-      logs:
-        storageClassName: "hostpath"
-  broker:
-    persistence:
-      store:
-        storageClassName: "hostpath"
-      logs:
-        storageClassName: "hostpath"
-
-elasticsearch:
-  persistence:
-    storageClassName: "hostpath"
-
-
-minio:
-  persistence:
-    storageClassName: "hostpath"
-
-etcd:
-  persistence:
-    storageClassName: "hostpath"
-
-milvus:
-  persistence:
-    storageClassName: "hostpath"
-

helm/charts/opencoze/values.yaml

@@ -14,7 +14,7 @@ mysql:
   user: coze
   password: coze123
   persistence:
-    storageClassName: "opencoze-data"
+    storageClassName: ""
     size: "50Gi"
   initScripts:
     - files/mysql/init.sql
@@ -31,7 +31,7 @@ redis:
   allowEmptyPassword: "yes"
   password: ""
   persistence:
-    storageClassName: "opencoze-data"
+    storageClassName: ""
     size: "50Gi"
 
 # -- coze-server configuration
@@ -41,8 +41,9 @@ cozeServer:
   replicaCount: 1
 
   image:
-    repository: opencoze-cn-beijing.cr.volces.com/iac/opencoze
-    pullPolicy: IfNotPresent
+    repository: opencoze/opencoze
+    # -- Keep the mirror up to date
+    pullPolicy: Always
     tag: 'latest'
 
   service:
@@ -106,10 +107,10 @@ rocketmq:
       tag: 5.3.2
     persistence:
       store:
-        storageClassName: "opencoze-data"
+        storageClassName: ""
         size: "20Gi"
       logs:
-        storageClassName: "opencoze-data"
+        storageClassName: ""
         size: "20Gi"
     resources:
       limits:
@@ -146,10 +147,10 @@ rocketmq:
       flushDiskType = ASYNC_FLUSH
     persistence:
       store:
-        storageClassName: "opencoze-data"
+        storageClassName: ""
         size: "20Gi"
       logs:
-        storageClassName: "opencoze-data"
+        storageClassName: ""
         size: "20Gi"
     resources:
       limits:
@@ -170,7 +171,7 @@ elasticsearch:
   password: ""
   persistence:
     enabled: true
-    storageClassName: "opencoze-data"
+    storageClassName: ""
     accessModes:
       - ReadWriteOnce
     size: 50Gi
@@ -192,7 +193,7 @@ minio:
     port: 9000
     consolePort: 9001
   persistence:
-    storageClassName: "opencoze-data"
+    storageClassName: ""
     size: "50Gi"
   resources:
     limits:
@@ -208,7 +209,7 @@ etcd:
     repository: bitnami/etcd
     tag: 3.5
   persistence:
-    storageClassName: "opencoze-data"
+    storageClassName: ""
     size: "20Gi"
 
 milvus:
@@ -218,7 +219,7 @@ milvus:
     tag: v2.5.10
   bucketName: milvus
   persistence:
-    storageClassName: "opencoze-data"
+    storageClassName: ""
     size: "20Gi"
 
 kibana: