2012-05-16 12 views
5

Estoy buscando un lugar para comenzar a solucionar este problema.Amazon-SQS + Django-Aplery crea miles de colas (una cola para cada mensaje)

aquí son los cambios realizados en el settings.py

#Rabbit MQ settings 
#=============================================================================== 
# BROKER_HOST = "localhost" 
# BROKER_PORT = 5672 
# BROKER_USER = "vei_0" 
# BROKER_PASSWORD = "1234" 
# BROKER_VHOST = "videoencoder" 
#=============================================================================== 




DEFAULT_FILE_STORAGE = 'storages.backends.s3boto.S3BotoStorage' 
AWS_ACCESS_KEY_ID = "xxxx" 
AWS_SECRET_ACCESS_KEY = "xxxx" 
AWS_STORAGE_BUCKET_NAME = "images" 
#Amazon SQS settings. 
BROKER_TRANSPORT = 'sqs' 
BROKER_TRANSPORT_OPTIONS = { 
    'region': 'us-east-1', 
} 
BROKER_USER = AWS_ACCESS_KEY_ID 
BROKER_PASSWORD = AWS_SECRET_ACCESS_KEY 
CELERY_DEFAULT_QUEUE = 'hardwaretaskqueue' 
CELERY_QUEUES = { 
    CELERY_DEFAULT_QUEUE: { 
     'exchange': CELERY_DEFAULT_QUEUE, 
     'binding_key': CELERY_DEFAULT_QUEUE, 
    } 
} 


CELERYD_CONCURRENCY = 2 
CELERY_TASK_RESULT_EXPIRES = 120 
CELERY_RESULT_BACKEND = "amqp" 

Me desperté esta mañana a un mensaje de Amazon diciendo "¿Se refiere a hacer unas colas bijillion?"

+0

+1 para el mensaje divertido de Amazon ya :) –

+0

mi clave secreta tiene una barra inclinada en ella. ¿Podría ser este el problema? – michael

Respuesta

9

Al usar el CELERY_RESULT_BACKEND = 'amqp', se crea una nueva cola para cada mensaje de resultado. Para evitar esto, simplemente puede usar otro CELERY_RESULT_BACKEND, como una base de datos o Redis. O si no está interesado en los resultados, puede configurar CELERY_IGNORE_RESULT = True.

+0

¿Se eliminan las colas cuando se lee el mensaje de resultados? – michael

+0

Las colas se crean como eliminación automática según la especificación AMQP, pero no pude decirle los detalles de cómo maneja SQS esa bandera. –

Cuestiones relacionadas