第十章：自動化你的仕事 - FastAPIでCron Jobs（定時タスク）を実装する

あなたの打刻システムが1ヶ月間稼働した後、上司はあなたをオフィスに呼び出し、嬉しそうにこう言いました：「システムは素晴らしい！ただ...あの...私が毎晩退社前に手動でバックエンドにログインして『遅刻者リストをエクスポート』をクリックするのが少し面倒だ。このシステムは毎晩6時に、今日の遅刻者を自動的にLineで送信できないだろうか？」

もし「定時タスク」の実装方法を知らない場合、あなたは非常に悲惨な光景を想像するかもしれません：毎日17:55にアラームを設定し、時間になったら手動でキーボードを叩いてAPIをトリガーする。これは全くエンジニアらしくありません。

現代的なソフトウェア開発では、このような機能には専用の専門用語があります：Cron Jobs（スケジュールタスク）。 これはソフトウェア世界の「見えないアラーム」のようなもので、時間が来るとバックグラウンドで自動的に面倒な仕事をやってくれます。

🎯 本章の目標

1. Python界最強の非同期スケジューリングライブラリAPSchedulerを理解する。
2. FastAPIのライフサイクル（lifespan）とバックグラウンドタスクの統合について学ぶ。
3. データベースを自動的にクエリし、Lineを通じて通知を自動送信する定時タスクを作成する。

---

⏰ ステップ1：スケジューリングライブラリ（APScheduler）のインストール

Pythonエコシステムには多くのスケジューリングライブラリがあります（例えばシンプルなscheduleや大規模なCeleryなど）が、FastAPIのような「非同期（Async）」を特徴とするモダンなフレームワークでは、軽量で非同期をサポートするAPSchedulerが業界で最も推奨されています。

ターミナルを開き（venvを忘れずに起動してください！）、以下のコマンドを実行してインストールします：

pip install apscheduler

---

🚀 ステップ2：AIに「日次遅刻レポート」スクリプトを書かせる

FastAPIで定時タスクを設定する際に最もハマりやすいのは、「FastAPIサーバーと一緒に起動させ、互いにブロックしないようにする方法」です。最新のlifespan実装を使って、AIに直接書かせることができます。

🔥【Vibe Prompt 実践呪文】 FastAPIのLine Botを開発中です。定時スケジュールタスク（Cron Job）を追加する必要があります。 要件は以下の通りです： 1. apschedulerのAsyncIOSchedulerをインポートする。 2. 毎日18:00に自動実行される非同期関数daily_late_report()を作成する。 3. この関数内で、データベースから当日の遅刻社員リスト配列を取得し、日本語のレポート文字列に組み立てる仮ロジックを記述する。 4. line-bot-sdk v3のapi.push_message機能を使用して、このレポートテキストをボス（BOSS_LINE_ID変数を記入用に残す）にプッシュ通知する。 5. （重要）このSchedulerをFastAPI最新版で推奨されるlifespan（ライフサイクル）イベントに正しくバインドして起動・停止させる。

AIが生成するコードは、あなたのメインプログラムに非常にエレガントに統合されます：

import os
from apscheduler.schedulers.asyncio import AsyncIOScheduler
from fastapi import FastAPI
from contextlib import asynccontextmanager
from linebot.v3.messaging import Configuration, ApiClient, MessagingApi, PushMessageRequest, TextMessage

# LineのキーとボスのIDを設定
CHANNEL_ACCESS_TOKEN = os.getenv("LINE_CHANNEL_ACCESS_TOKEN")
BOSS_LINE_ID = os.getenv("BOSS_LINE_ID") # ボスのLine ID（通常Uで始まる）

configuration = Configuration(access_token=CHANNEL_ACCESS_TOKEN)

# 💼 定時実行するコアタスクを定義
async def daily_late_report():
    print("⏰ [CronJob] 日次遅刻レポート生成を開始...")
    
    # TODO: ここは将来Supabaseデータベースから実際のデータを取得するクエリに置き換える
    late_users = ["王小明 (15分遅刻)", "李小華 (未打刻)"]
    
    if not late_users:
        report_text = "ボス、本日は全社員が時間通りに出勤し、遅刻者はありませんでした！🎉"
    else:
        report_text = "ボス、本日の出勤異常者リストは以下の通りです：\n\n" + "\n".join(late_users)
    
    # Messaging APIを使用してボスにメッセージをプッシュ
    try:
        with ApiClient(configuration) as api_client:
            line_bot_api = MessagingApi(api_client)
            line_bot_api.push_message(
                PushMessageRequest(
                    to=BOSS_LINE_ID,
                    messages=[TextMessage(text=report_text)]
                )
            )
        print("✅ [CronJob] レポートのプッシュ通知に成功！")
    except Exception as e:
        print(f"❌ [CronJob] プッシュ通知失敗：{e}")

# 🔄 FastAPIのライフサイクル（Lifespan）を設定
@asynccontextmanager
async def lifespan(app: FastAPI):
    # サーバー起動時：アラームを初期化して起動
    scheduler = AsyncIOScheduler()
    # 毎日18時0分に実行（テスト用に"* * * * *"に変更して毎分実行も可能）
    scheduler.add_job(daily_late_report, 'cron', hour=18, minute=0)
    scheduler.start()
    print("🕒 Schedulerが起動しました！スケジュールタスク待機中。")
    
    yield # ここはFastAPIサーバーが実行中であることを示す...
    
    # サーバーシャットダウン時：アラームを安全に停止し、リソースを解放
    scheduler.shutdown()
    print("🛑 Schedulerが安全に停止しました。")

# FastAPIアプリケーションを起動
app = FastAPI(lifespan=lifespan)

このコードがあれば、uvicorn main:appをサーバー上で実行すると、FastAPIはバックグラウンドで時計を見ながらカウントダウンします。 18時ちょうどになると、誰もクリックし��くても、ボスの携帯に「ピロリン」と音が鳴り、新鮮な遅刻者リストが届きます。ボスはあなたを非常にプロフェッショナルで、まるで霊能力者のようなソフトウェアプロバイダーだと思うでしょう。

---

💼 [ビジネス応用シナリオ] 全てを自動化可能

この「時間魔法」であるCron Jobを使えば、打刻システムのレポートだけでなく、「月額料金（SaaS）」を徴収できる無数の自動化サービスを開発できます：

1. 財務督促ボット：毎月5日に、月額料金を未払いの顧客リストをデータベースから自動的に抽出し、Lineのリッチメニューで支払いリマインダーを送信。さらには緑界（ECPay）の専用支払いリンクを添付。
2. ECカート回収：ユーザーが商品をカートに入れて24時間以上経過しても決済しない場合、自動的に「期間限定10%オフクーポン」を送信し、コンバージョン率を向上。
3. 日次天気・占いサブスクリプションサービス：毎朝7:30に、中央気象署から天気APIを自動取得し、購読会員全員に送信。

夜中にシステムがあなたのために働いてくれる、これこそがソフトウェアエンジニアにとって最もロマンチックなことです。次章で���、クラウドプラットフォームごとに異なるCronjobのサポート問題を解決する、サーバーデプロイの最後のピースを紹介します！