Python Flask + asyncio 写了一个数据采集的接口,一直报错,求大佬帮忙给治下~~~
先贴出来错误: RuntimeError: There is no current event loop in thread 'Thread-2'. 问题描述: 我使用 asyncio,aiohttp 进行了数据的抓取,想把这一模块封装成一个接口,调用接口的时候就会报错。 本人小白- - 对 flask 理解不深,不知道是接口写的有问题,还是哪里的问题。
贴出代码: 开启事件循环: def run(self, name, sku, page_start, page_end, sort, price_start, price_end): loop = asyncio.get_event_loop() asyncio.set_event_loop(loop) loop.run_until_complete( self.async_run(start_page, end_page, goods_name, rank_type, price))
flask 接口:
-- coding: utf-8 --
import flask import json import asyncio from flask import Flask, request from jd_global_shopping import jd_qqg
app = Flask(name) jd = jd_qqg()
@app.route("/global_shopping", methods=["POST"]) def check(): jd = jd_qqg() params = flask.request.json res = {'return_code': '200', 'return_info': '处理成功', 'result': ''}
if params:
name = params.get('name')
sku = params.get('sku')
page_start = params.get('page_start')
page_end = params.get('page_end')
# type = params.get('type')
sort = params.get('sort')
price_start = params.get('price_start', '')
price_end = params.get('price_end', '')
if name and page_start and page_end and sort:
if type(name) != str:
res = {"error_code": 3003, "msg": "输入关键字格式错误"}
# elif 'item.jd.hk' not in sku or not sku.isdigit():
# res = {"error_code": 3004, "msg": "输入链接格式错误"}
elif not page_start.isdigit():
res = {"error_code": 3004, "msg": "输入页码格式错误"}
elif not page_end.isdigit():
res = {"error_code": 3004, "msg": "输入页码格式错误"}
elif not sort.isdigit():
res = {"error_code": 3004, "msg": "输入类型格式错误"}
else:
jd.run(name, sku, page_start, page_end, sort, price_start, price_end)
else:
res = {"error_code": 3007, "msg": "必填参数未填写"}
else:
res = {“error_code”:3002,“msg”:“入参必须是 json 类型”}
return json.dumps(res, ensure_ascii=False)
if name == "main": app.run(port=8888, debug=True)
Python Flask + asyncio 写了一个数据采集的接口,一直报错,求大佬帮忙给治下~~~
在线等,求各位大佬解答~~~
我无法理解你的问题
别沉啊,大佬们吃完晚饭快来看啊
解决了,想听听各位大佬的高见
最近在学习 asyncio 和 aiohttp 的相关知识, 和 lz 共勉.
先看错误RuntimeError: There is no current event loop in thread 'Thread-2'
这个说明在 thread-2 的线程中没有事件循环
asyncio 中,
先要创建一个 get_event_loop 的对象,
然后
需要生成一个类型是 list 的 tasks
最近把 tasks 放入 run 中进行循环处理
看 lz 的 run 代码<br>def run(self, name, sku, page_start, page_end, sort, price_start, price_end): <br> loop = asyncio.get_event_loop() <br> asyncio.set_event_loop(loop)<br> loop.run_until_complete(self.async_run(start_page, end_page, goods_name, rank_type, price))<br>
没有发现有 tasks 的任务…感觉问题就出现在这里…
不要用 asyncio.get_event_loop()
直接 asyncio.new_event_loop()
一针见血,解决问题

