Amazon-SQS + Django-Sellerie erstellt Tausende von Warteschlangen (eine Warteschlange für jede Nachricht)

Question

Ich bin auf der Suche nach einem Ort, um dieses Problem zu beheben.

hier sind die in der settings.py Änderungen

#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" 

ich heute morgen von amazon auf eine Nachricht aufgewacht sagen: „Haben Sie eine bijillion Warteschlangen machen bedeuten zu?“

Answer 1

Bei Verwendung der CELERY_RESULT_BACKEND = 'amqp' wird für jede Ergebnisnachricht eine neue Warteschlange erstellt. Um dies zu vermeiden, können Sie einfach eine andere CELERY_RESULT_BACKEND wie eine Datenbank oder Redis verwenden. Oder wenn Sie nicht an den Ergebnissen interessiert sind, können Sie CELERY_IGNORE_RESULT = True setzen.