chore: 更新配置并优化任务错误处理
将数据库、Redis、Consul及Jaeger配置切换至新环境地址,并在worker中忽略"Invalid video_url"与"Invalid audio track"错误,同时补充模型调用成功日志。
This commit is contained in:
12
config.yml
12
config.yml
@@ -28,10 +28,10 @@ database:
|
|||||||
timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性,为true时CreatedAt/UpdatedAt/DeletedAt都将失效
|
timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性,为true时CreatedAt/UpdatedAt/DeletedAt都将失效
|
||||||
model_gateway:
|
model_gateway:
|
||||||
- type: "pgsql"
|
- type: "pgsql"
|
||||||
host: "192.168.3.30"
|
host: "116.204.74.41"
|
||||||
port: "5432"
|
port: "15432"
|
||||||
user: "postgres"
|
user: "postgres"
|
||||||
pass: "123456"
|
pass: "Bjang09@686^*^"
|
||||||
name: "model-gateway"
|
name: "model-gateway"
|
||||||
prefix: ""
|
prefix: ""
|
||||||
role: "master"
|
role: "master"
|
||||||
@@ -50,14 +50,14 @@ database:
|
|||||||
|
|
||||||
redis:
|
redis:
|
||||||
default:
|
default:
|
||||||
address: 192.168.3.30:6379
|
address: 116.204.74.41:6379
|
||||||
db: 0
|
db: 0
|
||||||
|
|
||||||
consul:
|
consul:
|
||||||
address: 192.168.3.30:8500
|
address: 116.204.74.41:8500
|
||||||
|
|
||||||
jaeger:
|
jaeger:
|
||||||
addr: 192.168.3.30:4318
|
addr: 116.204.74.41:4318
|
||||||
|
|
||||||
# 本地调试用:可选自动执行 worker/cleaner(默认关闭)
|
# 本地调试用:可选自动执行 worker/cleaner(默认关闭)
|
||||||
asynch:
|
asynch:
|
||||||
|
|||||||
@@ -72,7 +72,9 @@ func (w *asyncWorker) handleOne(ctx context.Context, task *entity.ModelGatewayTa
|
|||||||
}
|
}
|
||||||
|
|
||||||
if !strings.Contains(err.Error(), "Timeout") &&
|
if !strings.Contains(err.Error(), "Timeout") &&
|
||||||
!strings.Contains(err.Error(), "InternalServiceError") {
|
!strings.Contains(err.Error(), "InternalServiceError") &&
|
||||||
|
!strings.Contains(err.Error(), "Invalid video_url") &&
|
||||||
|
!strings.Contains(err.Error(), "Invalid audio track") {
|
||||||
w.failTask(ctx, task, startTime, err.Error())
|
w.failTask(ctx, task, startTime, err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -395,6 +397,7 @@ func InvokeModel(ctx context.Context, model *entity.ModelGatewayModel, body map[
|
|||||||
msg := string(b)
|
msg := string(b)
|
||||||
return nil, fmt.Errorf("模型服务返回非2xx: %d, body=%s", resp.StatusCode, msg)
|
return nil, fmt.Errorf("模型服务返回非2xx: %d, body=%s", resp.StatusCode, msg)
|
||||||
}
|
}
|
||||||
|
g.Log().Debugf(ctx, "[执行任务][模型调用成功] StatusCode=%v", resp.StatusCode)
|
||||||
return b, nil
|
return b, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user