|
@@ -39,7 +39,8 @@ def delSpiderLink():
|
|
|
if spider_link:
|
|
|
return jsonify({'code': 200, 'message': '抓取名单删除成功', 'del_link': spider_link})
|
|
|
else:
|
|
|
- return jsonify({'code': 400, 'message': '抓取名单删除失败', 'del_link': spider_link, 'spider_link': spider_links})
|
|
|
+ return jsonify(
|
|
|
+ {'code': 400, 'message': '抓取名单删除失败', 'del_link': spider_link, 'spider_link': spider_links})
|
|
|
|
|
|
|
|
|
@app.route("/v1/crawler/task/getcategory", methods=["GET"])
|
|
@@ -117,7 +118,7 @@ def getSource():
|
|
|
# 获取传入的params参数
|
|
|
get_data = request.args.to_dict()
|
|
|
# # 对参数进行操作
|
|
|
- sql = 'select source, task_type, spider_name, machine, source_desc, task_type_desc, spider_name_desc from crawler_source'
|
|
|
+ sql = 'select * from crawler_source'
|
|
|
|
|
|
result = mysql_con.get_values(sql)
|
|
|
if not result:
|
|
@@ -143,7 +144,7 @@ def getSource():
|
|
|
except Exception as e:
|
|
|
return jsonify({'code': '400', 'message': '获取数据源信息失败'})
|
|
|
|
|
|
- return jsonify({'code': '200', 'result': source_list})
|
|
|
+ return jsonify({'code': '200', 'result': {'source': source_list}})
|
|
|
|
|
|
|
|
|
@app.route("/v1/crawler/task/checkrepeat", methods=["POST"])
|