如何解决RuntimeError:flask 中的线程中没有当前事件循环?
实际上我想在启动我的烧瓶应用程序时运行 autoreminder.py 并且 autoreminder.py 应该在每 10 秒后在后台调用
autoreminder.py
import asyncio
import aiohttp
from database import DBHelper
MESSAGE_TO_SEND = 'Please Complete Your Task'
ACCESS_TOKEN = access_token
db = DBHelper()
async def taskReminder(memberID):
data = {
"recipient": { "id": memberID },"message": { "text": MESSAGE_TO_SEND }
}
async with aiohttp.ClientSession() as session:
async with session.post("https://graph.facebook.com/v8.0/me/messages?access_token="+ ACCESS_TOKEN,json=data) as response:
return await response.text()
def main():
loop = asyncio.get_event_loop()
Members = db.loadMembersNotCompletedTask()
coroutines = [taskReminder(''.join(member)) for member in Members]
loop.run_until_complete(asyncio.gather(*coroutines))
loop.close()
app.py
from flask import Flask,request,render_template
from apscheduler.schedulers.background import BackgroundScheduler
from autoreminder import main
app = Flask(__name__)
scheduler = BackgroundScheduler()
job = scheduler.add_job(main,'interval',seconds=10)
scheduler.start()
# Starting app
if __name__ == "__main__":
app.run(threaded=True)
RuntimeError: 线程中没有当前事件循环 'ThreadPoolExecutor-0_0'。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。