[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