リポジトリの原文
見出し、例、コード、表、リンク、参照画像を含む原文を表示しています。
Django + Celery 非同期タスク
Django でのバックグラウンドジョブと非同期処理。
使用時期
- メール送信をバックグラウンドで実行
- 重い処理をスケジュール
- 定期的なタスクを実行（日報、クリーンアップ）
- 外部API呼び出しをキューイング
- 複雑なワークフローを調整
セットアップ
1. Celery インストール
bash
pip install celery redis2. タスク定義
python
from celery import shared_task
@shared_task
def send_email(recipient):
# メール送信ロジック
pass3. ワーカー起動
bash
celery -A myapp worker -l infoタスク
非同期実行
python
send_email.delay(recipient) # すぐにキューに追加、非同期実行スケジューリング
python
from celery.schedules import crontab
app.conf.beat_schedule = {
'send-report-daily': {
'task': 'app.tasks.send_report',
'schedule': crontab(hour=9, minute=0),
},
}エラーハンドリング
- [ ] リトライロジック実装
- [ ] デッドレター処理
- [ ] ロギング構成
- [ ] モニタリング設定（Flower）
詳細については、ドキュメントを参照してください。
