myapp.py 479 B

1234567891011121314151617181920212223242526272829
  1. """myapp.py
  2. Usage:
  3. (window1)$ python myapp.py worker -l info
  4. (window2)$ python
  5. >>> from myapp import add
  6. >>> add.delay(16, 16).get()
  7. 32
  8. You can also specify the app to use with the `celery` command,
  9. using the `-A` / `--app` option::
  10. $ celery -A myapp worker -l info
  11. """
  12. from celery import Celery
  13. celery = Celery('myapp', broker='amqp://guest@localhost//')
  14. @celery.task()
  15. def add(x, y):
  16. return x + y
  17. if __name__ == '__main__':
  18. celery.start()