セロリとRabbitMQを使ったDjango

Question

私はCeleryとRabbitMQを使って電子メールを非同期で送る必要があるアプリケーションを開発しています。作業者が電子メールを送信したかどうかを確認するにはどうすればよいですか？

Answer 1

This SO explains what you are looking for.

基本的には、以下にあなたが何をする必要があるかです。

task_id = uuid() 
result = sendemail.apply_async((), task_id=task_id) 
Now you know exactly what the task_id is and can now use it to get the AsyncResult: 

# grab the AsyncResult 
result = celery.result.AsyncResult(task_id) 

# print the task id 
print result.task_id 
09dad9cf-c9fa-4aee-933f-ff54dae39bdf 

# print the AsyncResult's status 
print result.status 
SUCCESS 

# print the result returned 
print result.result 
'Email sent successfully'