diff --git a/workflow/service/flow/lambda_node.go b/workflow/service/flow/lambda_node.go index 520b973..241b43f 100644 --- a/workflow/service/flow/lambda_node.go +++ b/workflow/service/flow/lambda_node.go @@ -284,7 +284,7 @@ func VideoModelLambda(ctx context.Context, input any) (any, error) { } urlPrefix, err := utils.GetFileAddressPrefix(ctx) - newS := strings.ReplaceAll(urlPrefix, "http://cdn.redpowerfuture.com", g.Cfg().MustGet(ctx, "minioPrefix").String()) + newS := strings.ReplaceAll(urlPrefix, g.Cfg().MustGet(ctx, "filePrefix").String(), g.Cfg().MustGet(ctx, "minioPrefix").String()) if err != nil { return nil, err } diff --git a/workflow/service/flow/lambda_node_util.go b/workflow/service/flow/lambda_node_util.go index 8b00ef9..d5a1f92 100644 --- a/workflow/service/flow/lambda_node_util.go +++ b/workflow/service/flow/lambda_node_util.go @@ -505,7 +505,7 @@ func VideoConcat(ctx context.Context, videoUrls []string) (r any, err error) { } func GetFileBytesFromURL(ctx context.Context, fileUrl string) ([]byte, error) { - newS := strings.ReplaceAll(fileUrl, "http://cdn.redpowerfuture.com", g.Cfg().MustGet(ctx, "minioPrefix").String()) + newS := strings.ReplaceAll(fileUrl, g.Cfg().MustGet(ctx, "filePrefix").String(), g.Cfg().MustGet(ctx, "minioPrefix").String()) // 使用 GoFrame 客户端(自带超时、追踪、日志等能力) resp, err := g.Client().Get(ctx, newS) if err != nil {