[python] Celery의 큐(Queue) 설정은 어떻게 하는가?

Celery에서 큐를 설정하기 위해서는 CELERY_QUEUES 설정 사전(dictionary)을 사용합니다. 이 설정 사전은 큐의 이름과 해당 큐에서 작업을 처리할 워커(worker)의 수를 지정합니다. 다음은 예시입니다:

CELERY_QUEUES = {
    'default': {
        'exchange': 'default',
        'routing_key': 'default_queue',
    },
    'tasks': {
        'exchange': 'tasks',
        'routing_key': 'task_queue',
    },
}

여기서 'default''tasks'는 큐의 이름이며, 'exchange''routing_key'는 큐와 연결된 메시지 브로커와 통신할 때 사용되는 정보입니다.

'default' 큐는 기본 큐로 사용되며, 'tasks' 큐는 특정 작업들을 처리하는 목적으로 사용될 수 있습니다.

각 큐의 워커 수를 설정하기 위해서는 CELERY_WORKER_CONCURRENCY 설정을 사용합니다. 이 값은 각 큐에서 동시에 처리될 수 있는 작업의 수를 나타내며, 기본값은 4입니다.

예를 들어, 'default' 큐에서 동시에 2개의 작업을 실행하고, 'tasks' 큐에서 동시에 5개의 작업을 실행하려면 다음과 같이 설정할 수 있습니다:

CELERY_WORKER_CONCURRENCY = {
    'default': 2,
    'tasks': 5,
}

위의 설정을 Celery 애플리케이션의 설정 파일에 추가하면 큐와 워커 수를 설정할 수 있습니다. Celery를 실행할 때 이 설정 파일을 사용하면 설정된 큐와 워커 수로 작업을 처리할 수 있습니다.

더 자세한 정보와 설정 옵션에 대해서는 Celery 공식 문서를 참고하시기 바랍니다. Celery Documentation