|
|
@@ -12,7 +12,10 @@ from celery.schedules import crontab
|
|
|
import celery
|
|
|
|
|
|
app = Celery('tasks', backend ='redis://172.104.92.245', broker='redis://172.104.92.245')
|
|
|
+print('*****')
|
|
|
print(celery.utils.nodenames.gethostname())
|
|
|
+print('*****')
|
|
|
+
|
|
|
#rkey=app.request.delivery_info['routing_key']
|
|
|
|
|
|
|
|
|
@@ -23,6 +26,7 @@ app.conf.beat_schedule = {
|
|
|
# 'schedule': crontab(minute='*/1'),
|
|
|
'schedule': 30.0,
|
|
|
'args': (),
|
|
|
+ 'options':{'queue': 'foo'}
|
|
|
},
|
|
|
}
|
|
|
|
