如何用SQS運行django芹菜？

你好，我需要SQS生產運行django芹菜，但它不工作。我在我的設置這些配置：如何用SQS運行django芹菜？

BROKER_URL = 'sqs://' + AWS_ACCESS_KEY_ID + ':' + AWS_SECRET_ACCESS_KEY + '@' 
BROKER_TRANSPORT = 'sqs' 
BROKER_TRANSPORT_OPTIONS = { 
    'region': 'us-east-1', 
    'visibility_timeout': 3600, 
    # 'polling_interval': 0.3, 
    # 'queue_name_prefix': 'celery-', 
} 
BROKER_USER = AWS_ACCESS_KEY_ID 
BROKER_PASSWORD = AWS_SECRET_ACCESS_KEY 

CELERY_DEFAULT_QUEUE = 'mall4g-sqs' 
CELERY_QUEUES = { 
    CELERY_DEFAULT_QUEUE: { 
     'exchange': CELERY_DEFAULT_QUEUE, 
     'binding_key': CELERY_DEFAULT_QUEUE, 
    } 
} 
LOGGING = { 
    'version': 1, 
    'disable_existing_loggers': False, 
    'filters': { 
     'require_debug_false': { 
      '()': 'django.utils.log.RequireDebugFalse' 
     } 
    }, 
    'handlers': { 
     'mail_admins': { 
      'level': 'ERROR', 
      'filters': ['require_debug_false'], 
      'class': 'django.utils.log.AdminEmailHandler' 
     } 
    }, 
    'loggers': { 
     'django.request': { 
      'handlers': ['mail_admins'], 
      'level': 'ERROR', 
      'propagate': True, 
     }, 
    } 
} 


CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json' 
CELERY_ENABLE_UTC = True 
CELERYBEAT_SCHEDULE = { 
    'orders-expired-task': { 
     'task': 'orders.tasks.orders_expired', 
     'schedule': timedelta(hours=2) 
    }, 
    'remember-set-card': { 
     'task': 'orders.tasks.remember_set_credit_card', 
     'schedule': timedelta(days=14) 
    }, 
    'example': { 
     'task': 'orders.tasks.example', 
     'schedule': timedelta(minutes=5) 
    }, 

} 
# needed for worker monitoring 
CELERY_SEND_EVENTS = True 
# where to store periodic tasks (needed for scheduler) 
CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler" 
CELERY_TIMEZONE = 'UTC'

我不知道還有什麼添加或做什麼其他事情來做運行djcelery任務。請幫忙。

謝謝....

來源

2016-06-16 Pablo Alejandro

我剛剛設法連接了芹菜和SQS。

在我的設置：

BROKER_URL = 'sqs://' 
BROKER_TRANSPORT_OPTIONS = {'region': 'eu-west-1', 
          'visibility_timeout': 43200,# in seconds 
          'polling_interval': 3, 
          'queue_name_prefix':'repricer-stage-', 
          'CELERY_SEND_TASK_ERROR_EMAILS': True 
          }

以上，請注意BROKER_RUL = 'SQS：//'：

登錄憑證也可以使用環境變量 AWS_ACCESS_KEY_ID和AWS_SECRET_ACCESS_KEY設置，在這種情況下，經紀人的網址可能只有sqs：//。

source。

請注意，您需要工作人員與SQS進行交互。通過控制檯（在虛擬環境中）：

$ celery -A proj worker -l info

source

來源

2016-07-20 10:09:49 andyw

如果您使用的芹菜4.0.0和這行

app.config_from_object('django.conf:settings', namespace='CELERY')

命名空間可讓所有的芹菜相關的設置應該開始與CELERY

然後使用CELERY_BROKER_URL，CELERY_BROKER_TRANSPORT_OPTIONS。

來源

2016-12-09 13:43:29

如何用SQS運行django芹菜？

回答

相關問題