|
@@ -43,7 +43,7 @@ class Response(object):
|
|
|
except Exception as e:
|
|
|
return {
|
|
|
"error": "params error",
|
|
|
- "msg": str(e),
|
|
|
+ "message": str(e),
|
|
|
"info": self.params
|
|
|
}
|
|
|
|
|
@@ -208,26 +208,26 @@ class Response(object):
|
|
|
result = {
|
|
|
"traceId": self.trace_id,
|
|
|
"code": 0,
|
|
|
- "Message": "该请求还没处理"
|
|
|
+ "message": "该请求还没处理"
|
|
|
}
|
|
|
return result
|
|
|
case 1:
|
|
|
return {
|
|
|
"traceId": self.trace_id,
|
|
|
"code": 1,
|
|
|
- "Message": "已经执行完kimi"
|
|
|
+ "message": "已经执行完kimi"
|
|
|
}
|
|
|
case 2:
|
|
|
return {
|
|
|
"traceId": self.trace_id,
|
|
|
"code": 2,
|
|
|
- "Message": "已经执行完爬虫"
|
|
|
+ "message": "已经执行完爬虫"
|
|
|
}
|
|
|
case 3:
|
|
|
return {
|
|
|
"traceId": self.trace_id,
|
|
|
"code": 3,
|
|
|
- "error": "已经执行完 etl"
|
|
|
+ "message": "已经执行完 etl"
|
|
|
}
|
|
|
case 4:
|
|
|
# 修改任务状态为处理中
|
|
@@ -279,7 +279,7 @@ class Response(object):
|
|
|
return {
|
|
|
"traceId": self.trace_id,
|
|
|
"code": 101,
|
|
|
- "error": "该任务正在执行中"
|
|
|
+ "message": "该任务正在执行中"
|
|
|
}
|
|
|
|
|
|
async def deal(self):
|