twicas apiを叩いて配信開始時にコメント録画を始める

import os
import requests
import csv
import time
import datetime
import re

tokyo_tz = datetime.timezone(datetime.timedelta(hours=9))
dt = datetime.datetime.now(tokyo_tz)

# TwitCasting APIキー
ACCESS_TOKEN = "ここにアクセストークンを入れる"

HEADERS = {
    "Authorization": f"Bearer {ACCESS_TOKEN}",
    "X-Api-Version": "2.0"
}

USER_ID = "[任意の実況者のID]"  # 例：監視したいユーザーのID

response = requests.get(f"https://apiv2.twitcasting.tv/users/{USER_ID}/movies", headers=HEADERS)
data = response.json()

MOVIE_ID = data["movies"][0]["id"]                                          # 現在配信中のライブID
LIVE_TITLE = data["movies"][0]["title"]                                     # 配信中のライブ名
CSV_FILE = f"{str(dt.year)}{str(dt.month)}{str(dt.day)}_{LIVE_TITLE}.csv"   # csvファイル名生成
CSV_FILE = re.sub(r'[\\|/|:|?|.|"|<|>|\|]', '-', CSV_FILE)                  # ファイル名に使えないものは置換


# CSVファイルのヘッダーを書き込む（最初の1回だけ）
with open(CSV_FILE, mode='w', newline='', encoding='utf-8') as file:
    writer = csv.writer(file)
    writer.writerow(["id", "name", "screen_id", "message", "image", "profile"])  # ヘッダー行を変更

# 既に取得したコメントのIDを記録するセット（重複防止）
comment_ids = set()

def is_live(movie_id):
    """ライブ配信の状態を確認し、is_liveがFalseなら終了する"""
    try:
        response = requests.get(f"https://apiv2.twitcasting.tv/movies/{movie_id}", headers=HEADERS)
        data = response.json()
        return data.get("movie", {}).get("is_live", False)
    except Exception as e:
        print(f"ライブ状態の取得に失敗しました: {e}")
        return True  # 取得エラー時はとりあえず継続する

while is_live(MOVIE_ID):
    try:
        response = requests.get(f"https://apiv2.twitcasting.tv/movies/{MOVIE_ID}/comments", headers=HEADERS)
        data = response.json()

        with open(CSV_FILE, mode='a', newline='', encoding='utf-8') as file:
            writer = csv.writer(file)

            for comment in data["comments"]:
                if comment["id"] not in comment_ids:  # すでに記録されたコメントはスキップ
                    user = comment["from_user"]
                    writer.writerow([
                        comment["id"],          # コメントID
                        user["name"],           # ユーザー名
                        user["id"],             # screen_id（ユーザーID）
                        comment["message"],     # コメント内容
                        user.get("image", ""),  # プロフィール画像URL（なければ空白）
                        user.get("profile", "") # プロフィール情報（なければ空白）
                    ])
                    comment_ids.add(comment["id"])  # 記録済みIDを保存

        print("新しいコメントを追加しました。")

        time.sleep(5)  # 5秒待機してから再度取得

    except Exception as e:
        print(f"エラーが発生しました: {e}")
        time.sleep(10)  # エラー時は10秒待機してリトライ

print("ライブ配信が終了しました。処理を停止します。")