blob: 8ce38cfa10e28f5215a7349aa02a73d7468bffc1 (
plain)
1
2
3
4
5
6
|
from celery import Celery
app = Celery('tasks', broker='amqp://guest@horel.org//')
print app.control.rate_limit('tasks.NumFollowers', '4/m', destination=['celery@ip-172-31-42-158'], reply=True)
print app.control.rate_limit('tasks.ListFollowers', '4/m', destination=['celery@ip-172-31-42-158'], reply=True)
print app.control.rate_limit('tasks.NumFollowers', '1/h', destination=['celery@ip-172-31-42-159'], reply=True)
print app.control.rate_limit('tasks.ListFollowers', '1/h', destination=['celery@ip-172-31-42-159'], reply=True)
|
