1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

import requests
import datetime
import pytz
import json
import time

# --- 設定 ---
BEARER_TOKEN = "YOUR_BEARER_TOKEN_HERE" # 取得したBearer Tokenをここに貼り付けます
SEARCH_QUERY = "" # 検索したい単語またはフレーズ

# タイムゾーンの設定
JST = pytz.timezone('Asia/Tokyo')
UTC = pytz.utc

# --- 検索期間の設定 ---
# 現在時刻を取得し、UTCに変換
now_utc = datetime.datetime.now(UTC)

# end_time を現在時刻より1時間前に設定
adjusted_end_time_utc = now_utc - datetime.timedelta(hours=1)

# start_time は end_time の24時間前を基準にする
yesterday_utc = adjusted_end_time_utc - datetime.timedelta(days=1)


# APIクエリ用のISO 8601形式にフォーマット (RFC3339準拠)
start_time = yesterday_utc.strftime('%Y-%m-%dT%H:%M:%SZ')
end_time = adjusted_end_time_utc.strftime('%Y-%m-%dT%H:%M:%SZ') # 修正箇所

# --- APIエンドポイントとヘッダー ---
SEARCH_URL = "https://api.twitter.com/2/tweets/search/recent"
HEADERS = {
    "Authorization": f"Bearer {BEARER_TOKEN}"
}

# --- パラメータの設定 ---
PARAMS = {
    "query": SEARCH_QUERY,
    "start_time": start_time,
    "end_time": end_time,
    "tweet.fields": "created_at,author_id,public_metrics,lang",
    "expansions": "author_id",
    "user.fields": "name,username",
    "max_results": 100
}

# --- APIリクエストの実行 ---
def get_tweets():
    print(f"Searching for '{SEARCH_QUERY}' from {start_time} to {end_time}")
    response = requests.get(SEARCH_URL, headers=HEADERS, params=PARAMS)

    if response.status_code == 429:
        print("Rate limit exceeded. Waiting for 15 minutes...")
        time.sleep(15 * 60 + 10) # 15分と10秒待機
        # 待機後に再度リクエストを試みる場合は、この関数を再帰的に呼び出すか、ループで囲む
        return []
    elif response.status_code != 200:
        print(f"Error: {response.status_code}")
        print(response.json())
        return []

    data = response.json()
    # print(json.dumps(data, indent=2, ensure_ascii=False)) # デバッグ用に全レスポンスを表示

    if 'data' not in data:
        print("No tweets found for the specified query and time range, or 'data' key is missing.")
        return []

    tweets = data['data']
    users = {user['id']: user for user in data.get('includes', {}).get('users', [])}

    results = []
    for tweet in tweets:
        author = users.get(tweet['author_id'], {})
        results.append({
            "id": tweet['id'],
            "text": tweet['text'],
            "created_at": tweet['created_at'],
            "author_username": author.get('username'),
            "author_name": author.get('name'),
            "retweet_count": tweet['public_metrics'].get('retweet_count', 0),
            "like_count": tweet['public_metrics'].get('like_count', 0),
            "lang": tweet.get('lang')
        })
    return results

if __name__ == "__main__":
    retrieved_tweets = get_tweets()
    print(f"\n--- 取得したツイートの例 ({len(retrieved_tweets)}件) ---")
    for i, tweet in enumerate(retrieved_tweets[:5]):
        print(f"--- Tweet {i+1} ---")
        print(f"ユーザー: @{tweet['author_username']} ({tweet['author_name']})")
        print(f"日時: {tweet['created_at']}")
        print(f"本文: {tweet['text']}")
        print(f"RT/いいね: {tweet['retweet_count']}/{tweet['like_count']}")
        print("-" * 20)

1
2

Error: 429
{'title': 'Too Many Requests', 'detail': 'Too Many Requests', 'type': 'about:blank', 'status': 429}