git-sync/crawlab
1
0
Fork 0
mirror of https://github.com/crawlab-team/crawlab.git synced 2026-01-24 17:41:03 +01:00
Code Issues Packages Projects Releases Wiki Activity

添加打印日志

Browse Source
This commit is contained in:
陈景阳
2019-08-28 16:00:09 +08:00
parent c7e137a6aa
commit cae11e3796
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/services/spider.go
View File

@@ -295,6 +295,7 @@ func PublishSpider(spider model.Spider) (err error) {
return
}
channel := "files:upload"
log.Info("publish files.upload event, file id:" + msg.FileId)
if err = database.Publish(channel, string(msgStr)); err != nil {
log.Errorf(err.Error())
debug.PrintStack()
@@ -306,6 +307,7 @@ func PublishSpider(spider model.Spider) (err error) {
// 上传爬虫回调
func OnFileUpload(channel string, msgStr string) {
log.Info("received files.upload event, msgStr:" + msgStr)
s, gf := database.GetGridFs("files")
defer s.Close()
@@ -320,7 +322,7 @@ func OnFileUpload(channel string, msgStr string) {
// 从GridFS获取该文件
f, err := gf.OpenId(bson.ObjectIdHex(msg.FileId))
if err != nil {
log.Errorf("open file id" + msg.FileId + ", error: " + err.Error())
log.Errorf("open file id: " + msg.FileId + ", error: " + err.Error())
debug.PrintStack()
return
}