Advertisement
Guest User

Untitled

a guest
Mar 1st, 2017
118
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.82 KB | None | 0 0
  1. celery worker --workdir /mnt/src/ --config worker.celeryconfig -l debug -Q io_tasks -c 200 -P gevent --logfile=/var/log/celery.io_tasks.log --hostname=io_tasks.%h --without-heartbeat
  2.  
  3. [config]
  4. > app: default:0x7f449e691cf8 (.default.Loader)
  5. > transport: amqp://guest:**@localhost:5672//
  6. > results: disabled://
  7. > concurrency: 200 (gevent)
  8. > task events: OFF (enable -E to monitor tasks in this worker)
  9. [queues]
  10. > io_tasks exchange=io_tasks(direct) key=io_tasks
  11.  
  12.  
  13. # actual dockerized rabbitmq broker url (amqp://admin:**@172.17.0.3:5672//)
  14. broker_url = "amqp://{user}:{password}@{host}:{port}/".format(
  15. user=os.environ['RABBITMQ_ENV_RABBITMQ_USER'],
  16. password=os.environ['RABBITMQ_ENV_RABBITMQ_PASS'],
  17. host=os.environ['RABBITMQ_PORT_5672_TCP_ADDR'],
  18. port=os.environ['RABBITMQ_PORT_5672_TCP_PORT']
  19. )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement