|
@@ -185,6 +185,11 @@ func RunExtractTask(taskId string) {
|
|
|
if qu.ObjToString(v["sensitive"]) != "" { //去除含敏感词数据
|
|
|
continue
|
|
|
}
|
|
|
+ //根据标题判断是否抽取
|
|
|
+ b := IsExtract("title", qu.ObjToString(v["title"]), "")
|
|
|
+ if !b {
|
|
|
+ continue
|
|
|
+ }
|
|
|
_id := qu.BsonIdToSId(v["_id"])
|
|
|
//log.Debug(_id)
|
|
|
if !ext.IsRun {
|
|
@@ -610,7 +615,7 @@ func ExtRegPre(doc map[string]interface{}, j *ju.Job, in *RegLuaInfo, t *TaskInf
|
|
|
//抽取-规则
|
|
|
func ExtRegCore(extfrom string, doc map[string]interface{}, j *ju.Job, in *RegLuaInfo, et *ExtractTask) {
|
|
|
defer qu.Catch()
|
|
|
- //废标、流标、ppp等跳过
|
|
|
+ //根据field配置项目,是否抽取。例如:废标、流标等跳过,
|
|
|
b := IsExtract(in.Field, j.Title, j.Content)
|
|
|
if !b {
|
|
|
return
|