python flask+mongodb 完成一个定时任务
时间: 2023-07-01 10:12:22 浏览: 110
你可以使用Python中的APScheduler库来完成定时任务,并使用PyMongo库连接MongoDB数据库。下面是一个示例代码:
```python
from apscheduler.schedulers.blocking import BlockingScheduler
from pymongo import MongoClient
# 连接MongoDB数据库
client = MongoClient('mongodb://localhost:27017/')
db = client['test']
collection = db['tasks']
# 定义定时任务
def task():
# 在这里编写要执行的任务代码
print('This is a scheduled task')
# 创建定时任务调度器
scheduler = BlockingScheduler()
# 添加定时任务
scheduler.add_job(task, 'interval', minutes=1)
# 启动定时任务调度器
scheduler.start()
```
在上面的代码中,我们首先使用PyMongo库连接MongoDB数据库,并选择一个名为“test”的数据库和一个名为“tasks”的集合。接下来,我们定义一个名为“task”的函数,这个函数就是我们要定时执行的任务。最后,我们创建一个定时任务调度器,并使用`add_job()`方法向调度器添加一个每1分钟执行一次的定时任务。最后,我们启动定时任务调度器。
你可以在`task()`函数中编写任何你想要执行的任务代码,例如向MongoDB数据库中插入一条数据或者从MongoDB数据库中读取数据并进行处理等。
阅读全文