2012-05-16 16 views
5

मैं इस समस्या का निवारण शुरू करने के लिए एक स्थान की तलाश में हूं।अमेज़ॅन-एसक्यूएस + डीजेगो-सेलेरी हजारों कतार (प्रत्येक संदेश के लिए एक कतार) बनाता है

यहाँ 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" 

मैं अमेज़न से कहता हुआ एक संदेश आज सुबह उठा परिवर्तन कर रहे हैं "आप एक bijillion कतारों बनाने के लिए मतलब है?"

+0

+1 पहले से ही :) –

+0

मेरी गुप्त कुंजी में आगे की ओर स्लैश है। क्या यह समस्या हो सकती है? – michael

उत्तर

9

CELERY_RESULT_BACKEND = 'amqp' का उपयोग करते समय प्रत्येक परिणाम संदेश के लिए एक नई कतार बनाई जाती है। इससे बचने के लिए आप बस CELERY_RESULT_BACKEND जैसे डेटाबेस या रेडिस का उपयोग कर सकते हैं। या यदि आप परिणामों में रुचि नहीं रखते हैं तो आप CELERY_IGNORE_RESULT = True सेट कर सकते हैं। अमेज़ॅन से अजीब संदेश के लिए

+0

परिणाम संदेश पढ़े जाने पर कतार हटा दी गई हैं? – michael

+0

कतार AMQP spec प्रति ऑटो-डिलीट के रूप में बनाई गई हैं लेकिन मैं आपको यह बता नहीं सकता कि एसक्यूएस उस ध्वज को कैसे संभालता है। –

संबंधित मुद्दे