inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

실리콘밸리 엔지니어와 함께하는 샐러리(Celery)

Task Callback과 에러 다루기

celery 에서 task 작업 끝난 후 ack 받기

371

김홍근

작성한 질문수 2

1

안녕하세요. celery 수업 잘 듣고 있습니다.

제가 수업 내용을 활용 하여 test 코드를 작성 중입니다.

구조는 publisher(kombu), broker(redis), consumer(celery) 구성하고 있습니다.

질문은 celery 에 task가 작업이 끝난 후 결과를 broker 알리면 publisher 가 ack 를 받아 처리하는 구조가 가능 할까요?

django celery django-celery django-celery-beat

답변 2

0

김홍근

Publisher -> Broker -> Celery -> Broker -> Publisher

구조가 가능 한지에 대한 질문이 였습니다.

publisher 가 celery 에게 일을 시키면 일이 끝날 때까지 publisher 가 대기 하고 있다가 celery가 일이 끝나면 그 결과를 publisher가 받는 구조를 말씀 드렸습니다.

1

미쿡엔지니어

안녕하세요 김홍근님,

퍼블리셔는 말그대로 이벤트를 만드는 역할입니다. 퍼블리셔가 다시 이벤트를 받는다는 말은 데이터베이스에서 결과 레코드를 확인한다는 식은 생각으로 읽혀지는데 그러려면 퍼블리셔가 주기적으로 상태를 확인해야할 듯합니다 ㅎㅎ

0

김홍근

그렇다면 해당 작업에 대한 정보를 브로커(redis)에 볼수 있는 방법이 있나요??

 

1

미쿡엔지니어

플라워에서 작업내용을 브로커에서 뽑아오니 잘 살펴보시면 가능도 할 듯합니다

0

미쿡엔지니어

안녕하세요 김홍근님,

좀 이해가 안되는데요, 보통 Celery가 Consumer인데 그 결과는 데이터베이스나 Redis에 저장됩니다. Publisher는 이러한 Celery에게 일을 시키는 역할이라 약간 반대가 되었는데요?

순차적인 Flow가 Publisher -> Broker -> Celery -> DB/Broker가 될거 같습니다만.. 제가 질문을 잘못 이해했다면 말씀해 주세요.

Publisher -> Broker -> Celery -> Broker -> Celery도 가능은 합니다만...

감사합니다.

진도미확인 (진도가 안 넘어감)

0

39

1

자료 화면 문의

0

37

1

celery.py 위치

0

96

2

docker-compose

0

111

1

standalone_celery 에만 작성된 task 들은 호출할 수 없나요?

0

136

2

수업노트 github 주소가 404가 많아요

0

92

1

product level에서 celeryd를 사용하시나요?

0

239

1

celery의 로그 설정을 django의 settings.py에서 따로 해줘야 하는게 있을까요?

1

346

1

django에서 view나 api에서 request를 celery로 넘길 수 있을까요?

1

243

1

child process에 lock/좀비 프로세스가 발생하면 어떻게 처리되나요?

1

251

1

DLQ와 관련한 이전 질문의 추가 질문 입니다.

1

272

2

task 에러를 signal로 잡는 부분에 대해 질문 드립니다.

0

214

1

DLQ에 저장하는 패턴에 대해 질문 드립니다.

1

203

1

DLX에 대한 질문입니다.

1

153

1

기존 docker-compose는 admin의 깨져서 나옵니다.

1

206

2

실습에 문제가 많아 수업노트보기의 저장소 코드를 확인해봤습니다.

1

219

2

celery-standalone에 대한 질문입니다.

1

162

1

Celery Monitoring Tool, Flower에 대해 알아보기에 질문 있습니다.

1

528

3

group에서 keyword arg를 전송할 때에 대해 알고 싶습니다.

1

208

1

SNS 처럼 사용하기

1

177

1

셀러리 사용에 문의드립니다.

1

288

2

Task Routing 부분 보니까요

1

315

1

rate_limit

0

319

2

docker-compose

2

448

2