Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
- [config]
- > app: default:0x7f449e691cf8 (.default.Loader)
- > transport: amqp://guest:**@localhost:5672//
- > results: disabled://
- > concurrency: 200 (gevent)
- > task events: OFF (enable -E to monitor tasks in this worker)
- [queues]
- > io_tasks exchange=io_tasks(direct) key=io_tasks
- # actual dockerized rabbitmq broker url (amqp://admin:**@172.17.0.3:5672//)
- broker_url = "amqp://{user}:{password}@{host}:{port}/".format(
- user=os.environ['RABBITMQ_ENV_RABBITMQ_USER'],
- password=os.environ['RABBITMQ_ENV_RABBITMQ_PASS'],
- host=os.environ['RABBITMQ_PORT_5672_TCP_ADDR'],
- port=os.environ['RABBITMQ_PORT_5672_TCP_PORT']
- )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement