|
@@ -1700,9 +1700,9 @@ Celery是一个本身不提供队列服务,官方推荐使用RabbitMQ或Redis
|
|
|
# 将来实际部署项目的时候生产者、消费者、消息队列可能都是不同节点
|
|
# 将来实际部署项目的时候生产者、消费者、消息队列可能都是不同节点
|
|
|
beat_schedule={
|
|
beat_schedule={
|
|
|
'task1': {
|
|
'task1': {
|
|
|
- 'task': 'common.tasks.show_msg',
|
|
|
|
|
|
|
+ 'task': 'common.tasks.scheduled_task',
|
|
|
'schedule': crontab('*', '*', '*', '*', '*'),
|
|
'schedule': crontab('*', '*', '*', '*', '*'),
|
|
|
- 'args': ('刘强东,奶茶妹妹喊你回家喝奶啦', )
|
|
|
|
|
|
|
+ 'args': ('...', )
|
|
|
},
|
|
},
|
|
|
},
|
|
},
|
|
|
)
|
|
)
|
|
@@ -1710,8 +1710,8 @@ Celery是一个本身不提供队列服务,官方推荐使用RabbitMQ或Redis
|
|
|
|
|
|
|
|
```Python
|
|
```Python
|
|
|
@app.task
|
|
@app.task
|
|
|
- def show_msg(content):
|
|
|
|
|
- print(content)
|
|
|
|
|
|
|
+ def scheduled_task(*args, **kwargs):
|
|
|
|
|
+ pass
|
|
|
```
|
|
```
|
|
|
|
|
|
|
|
7. 启动Celery创建执行定时任务的beat(消息的生产者)。
|
|
7. 启动Celery创建执行定时任务的beat(消息的生产者)。
|