# 环境设置export X_BEARER_TOKEN="your-bearer-token"import osimport requestsbearer = os.environ["X_BEARER_TOKEN"]headers = {"Authorization": f"Bearer {bearer}"}# 搜索近期推文resp = requests.get(    "https://api.x.com/2/tweets/search/recent",    headers=headers,    params={"query": "claude code", "max_results": 10})tweets = resp.json()

# 环境设置 — 使用前请先加载export X_API_KEY="your-api-key"export X_API_SECRET="your-api-secret"export X_ACCESS_TOKEN="your-access-token"export X_ACCESS_SECRET="your-access-secret"import osfrom requests_oauthlib import OAuth1Sessionoauth = OAuth1Session(    os.environ["X_API_KEY"],    client_secret=os.environ["X_API_SECRET"],    resource_owner_key=os.environ["X_ACCESS_TOKEN"],    resource_owner_secret=os.environ["X_ACCESS_SECRET"],)

resp = oauth.post(    "https://api.x.com/2/tweets",    json={"text": "Hello from Claude Code"})resp.raise_for_status()tweet_id = resp.json()["data"]["id"]

def post_thread(oauth, tweets: list[str]) -> list[str]:    ids = []    reply_to = None    for text in tweets:        payload = {"text": text}        if reply_to:            payload["reply"] = {"in_reply_to_tweet_id": reply_to}        resp = oauth.post("https://api.x.com/2/tweets", json=payload)        resp.raise_for_status()        tweet_id = resp.json()["data"]["id"]        ids.append(tweet_id)        reply_to = tweet_id    return ids

resp = requests.get(    f"https://api.x.com/2/users/{user_id}/tweets",    headers=headers,    params={        "max_results": 10,        "tweet.fields": "created_at,public_metrics",    })

resp = requests.get(    "https://api.x.com/2/tweets/search/recent",    headers=headers,    params={        "query": "from:affaanmustafa -is:retweet",        "max_results": 10,        "tweet.fields": "public_metrics,created_at",    })

resp = requests.get(    "https://api.x.com/2/users/by/username/affaanmustafa",    headers=headers,    params={"user.fields": "public_metrics,description,created_at"})

# 媒体上传使用 v1.1 端点# 步骤 1：上传媒体media_resp = oauth.post(    "https://upload.twitter.com/1.1/media/upload.json",    files={"media": open("image.png", "rb")})media_id = media_resp.json()["media_id_string"]# 步骤 2：附带媒体发布resp = oauth.post(    "https://api.x.com/2/tweets",    json={"text": "Check this out", "media": {"media_ids": [media_id]}})

import timeremaining = int(resp.headers.get("x-rate-limit-remaining", 0))if remaining < 5:    reset = int(resp.headers.get("x-rate-limit-reset", 0))    wait = max(0, reset - int(time.time()))    print(f"Rate limit approaching. Resets in {wait}s")

resp = oauth.post("https://api.x.com/2/tweets", json={"text": content})if resp.status_code == 201:    return resp.json()["data"]["id"]elif resp.status_code == 429:    reset = int(resp.headers["x-rate-limit-reset"])    raise Exception(f"Rate limited. Resets at {reset}")elif resp.status_code == 403:    raise Exception(f"Forbidden: {resp.json().get('detail', 'check permissions')}")else:    raise Exception(f"X API error {resp.status_code}: {resp.text}")