Twitter API v2で、一定数以上リツイートされているツイートのみを取得したい

Question

前提

twitter api v2とpython3.10.4を使っています。クエリを用いて検索する際に、リツイート数が一定数以上のツイートを取得したいです。

実現したいこと

• リツイート数が一定数以上のツイートを取得する

該当のソースコード

こちらのサイトからお借りしています。

import datetime
import json
import time
import urllib
import requests
import tqdm


def request_search(bearer_token, params, max_count):
    # ツイートデータ
    tweets = []
    # 追加データ
    expanded = {
        "tweets": [],
        "users": [],
        "media": [],
        "places": [],
        "polls": [],
    }

    # 次のページのトークン
    next_token = None

    # 毎ページ処理を繰り返す
    while True:
        # `next_token` があるとき（＝初回以外）はパラメータに設定する
        if next_token is not None:
            params["next_token"] = next_token

        # API にリクエストを送信する
        url = "https://api.twitter.com/2/tweets/search/recent"
        encoded_params = urllib.parse.urlencode(params)
        headers = {"Authorization": f"Bearer {BEARER_TOKEN}"}
        res = requests.request(
            "GET", url, params=encoded_params, headers=headers)
        print("*", end="")

        # rate limit に引っかかったときは解除されるまで待つ
        if res.status_code == 429:
            rate_limit_reset = int(res.headers["x-rate-limit-reset"])
            now = time.mktime(datetime.datetime.now().timetuple())
            wait_sec = int(rate_limit_reset - now)
            desc = f"Waiting for {wait_sec} seconds"
            for _ in tqdm.trange(wait_sec, desc=desc):
                time.sleep(1)

        # それ以外のエラーのときはエラーを投げる
        elif res.status_code != 200:
            raise Exception(res.status_code, res.text)

        # 正常に処理されたとき
        else:
            res_json = res.json()

            # データが0件になったら終了する
            if res_json["meta"]["result_count"] == 0:
                break

            # リストにデータを追加する
            tweets += res_json["data"]
            print(f"{len(tweets)}件のツイートを取得しました。")

            # リストに追加データを追加する
            if res_json.get("includes"):
                includes = res_json["includes"]
                for k, v in expanded.items():
                    if includes.get(k):
                        expanded[k] += includes[k]

            # `next_token` がない（＝データを全て取得）or 取得数の上限に達したときは終了する
            next_token = res_json.get("meta").get("next_token")
            if next_token is None or len(tweets) >= max_count:
                break

    return tweets[:max_count], expanded


def export_json(fpath, data):
    with open(fpath, "w", encoding="utf-8") as f:
        json.dump(data, f, ensure_ascii=False)


if __name__ == "__main__":
    bearer_token = ""  # Twitter API のトークン
    max_count = 10  # ツイート取得数の上限（Essential で最大50万件、Elevated で最大200万件）

    # API のパラメータ
    params = {
        "query": "雨 綺麗 -is:retweet min_retweets:100",
        "start_time": "2022-07-16T00:00:00+09:00",
        "end_time": "2022-07-16T23:59:59+09:00",
        # "expansions": "attachments.poll_ids,attachments.media_keys,author_id,entities.mentions.username,geo.place_id,in_reply_to_user_id,referenced_tweets.id,referenced_tweets.id.author_id",
        "max_results": "10",
        # "media.fields": "duration_ms,height,media_key,preview_image_url,type,url,width,public_metrics",
        # "place.fields": "contained_within,country,country_code,full_name,geo,id,name,place_type",
        # "poll.fields": "duration_minutes,end_datetime,id,options,voting_status",
        # "tweet.fields": "attachments,author_id,context_annotations,conversation_id,created_at,entities,geo,id,in_reply_to_user_id,lang,public_metrics,possibly_sensitive,referenced_tweets,reply_settings,source,text,withheld",
        # "user.fields": "created_at,description,entities,id,location,name,pinned_tweet_id,profile_image_url,protected,public_metrics,url,username,verified,withheld",
    }

    # ツイートを取得する
    tweets, expanded = request_search(bearer_token, params, max_count)

    # データを json に書き出す
    export_json("tweets.json", tweets)
    export_json("expanded.json", expanded)

試したこと

v1.1と同様にmin_retweets:100のように指定しましたが、実行されませんでした。

Exception: (400, '{"errors":[{"parameters":{"query":["雨 綺麗 -is:retweet min_retweets:100"]},"message":"There were errors processing your request: Reference to invalid operator \'min_retweets\'. Operator is not available in current product or product packaging. Please refer to complete available operator list at http://t.co/operators. (at position 18), Reference to invalid field \'min_retweets\' (at position 18)"}],"title":"Invalid Request","detail":"One or more parameters to your request was invalid.","type":"https://api.twitter.com/2/problems/invalid-request"}')

補足

とりあえず手当たり次第に検索しその中からリツイート数の多いものを見つけるのではなく、検索段階でフィルタを掛けたいです。よろしくお願いします。

Comments

[can110]

提示ソースにはmin_retweetsは指定されていませんが、意図通りのコードでしょうか。
また実行されなかったとは具体的にどのような結果になったということでしょうか。

[amemidaifuku]

ご指摘ありがとうございます．クエリへのmin_retweetsオプションの記入は，twitter API v2のドキュメント(https://developer.twitter.com/en/docs/twitter-api/tweets/search/integrate/build-a-query)に記載がなく，動作しなくて当然であると思い記入していませんでした．
ソースへの追記，エラー文の追記を行いました．よろしくお願いします．

[can110]

https://developer.twitter.com/en/docs/twitter-api/tweets/search/migrate
の対応表(Filtering operator comparison)でもv2では空（未対応）なので、そもそも不可能だと思うのですが
v1.1系は使わず、どうしてもv2で実現したいということでしょうか。

[amemidaifuku]

その通りです。
URLのような比較ページがあるのですね、確認不足でした。公式で提供されていないとなると難しそうですね…。