Guest User

Untitled

a guest
Aug 15th, 2018
113
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.33 KB | None | 0 0
  1. """ Message Queue Stuff """
  2. MQ_PROTOCOL = os.environ.get('MQ_PROTOCOL', 'amqp')
  3. MQ_USER = os.environ.get(
  4. 'MQ_USER', 'makecents')
  5. MQ_PASS = os.environ.get(
  6. 'MQ_PASS', 'makecents')
  7. MQ_HOST = os.environ.get('MQ_HOST', 'localhost')
  8. MQ_PORT = os.environ.get('MQ_PORT', '5672')
  9.  
  10. NEW_MQ_NAME = 'makecents'
  11.  
  12. MQ_CONFIG_DICT = {
  13. 'protocol': MQ_PRTOCOL
  14. 'vhost': MQ_VHOST
  15. 'user': MQ_USER,
  16. 'password': MQ_PASS,
  17. 'host': MQ_HOST,
  18. 'port': MQ_PORT
  19. }
  20.  
  21. MQ_CONN_FORMAT = '{protocol}://{user}:{password}@{host}:{port}/{vhost}'
  22.  
  23. MQ_URI_DEFAULT = (MQ_CONN_FORMAT.format(
  24. **MQ_CONFIG_DICT))
  25.  
  26. # This should be the whole MQ_CONN_FORMAT
  27. SOCKETIO_MESSAGE_QUEUE = os.environ.get(
  28. 'SOCKETIO_MESSAGE_QUEUE', MQ_UR_DEFAULT)
  29.  
  30. """ CELERY CONF """
  31. # TODO we need to pass the basic auth info to CELERY_BROKER_URL/BACKEND.
  32. CELERY_BROKER_URL = os.environ.get(
  33. 'CELERY_BROKER_URL',
  34. MQ_URI_DEFAULT) # MQ_CONN_URI_NEW)
  35. CELERY_RESULT_BACKEND = os.environ.get(
  36. 'CELERY_RESULT_BACKEND',
  37. MQ_URI_DEFAULT) # MQ_CONN_URI_NEW)
  38. CELERY_CONFIG = {
  39. 'CELERY_RESULT_BACKEND': CELERY_RESULT_BACKEND,
  40. 'CELERY_BROKER_URL': CELERY_BROKER_URL}
  41.  
  42. CELERY_CONN_URI_DEFAULT = (MQ_CONN_FORMAT.format(
  43. **MQ_CONFIG_DICT))
Add Comment
Please, Sign In to add comment