Twitter 到 Discord Webhook：分步配置指南 (2026)

const WEBHOOK_URL = 'https://discord.com/api/webhooks/YOUR_ID/YOUR_TOKEN';

function normalizeHandle(handle) {
  return String(handle ?? '').replace(/^@/, '');
}

async function sendTweetAlert(tweet) {
  const handle = normalizeHandle(tweet.author.handle);
  const embed = {
    title: `@${handle}`,
    description: tweet.text,
    color: 3447003, // Blue
    url: tweet.link ?? `https://x.com/${handle}/status/${tweet.tweetId}`,
    fields: [],
    footer: { text: 'TweetStream Alert' },
    timestamp: new Date().toISOString(),
  };

  // Add detected tokens as fields
  if (tweet.tokens?.length) {
    for (const token of tweet.tokens) {
      embed.fields.push({
        name: token.symbol,
        value: `$${token.price} | ${token.chain}`,
        inline: true,
      });
    }
  }

  const response = await fetch(WEBHOOK_URL, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ embeds: [embed] }),
  });

  if (response.status === 429) {
    const retryAfter = response.headers.get('Retry-After');
    console.log(`Rate limited. Retry after ${retryAfter}s`);
  }
}

import requests
import time

WEBHOOK_URL = "https://discord.com/api/webhooks/YOUR_ID/YOUR_TOKEN"

def normalize_handle(handle: object) -> str:
    return str(handle or "").removeprefix("@")

def send_tweet_alert(tweet: dict) -> None:
    handle = normalize_handle(tweet.get("author", {}).get("handle"))
    embed = {
        "title": f"@{handle}",
        "description": tweet["text"],
        "color": 3447003,  # Blue
        "url": tweet.get("link") or f"https://x.com/{handle}/status/{tweet['tweetId']}",
        "fields": [],
        "footer": {"text": "TweetStream Alert"},
    }

    # Add detected tokens
    for token in tweet.get("tokens", []):
        embed["fields"].append({
            "name": token["symbol"],
            "value": f"${token['price']} | {token['chain']}",
            "inline": True,
        })

    payload = {"embeds": [embed]}
    resp = requests.post(WEBHOOK_URL, json=payload)

    if resp.status_code == 429:
        retry_after = resp.json().get("retry_after", 1)
        time.sleep(retry_after)
        requests.post(WEBHOOK_URL, json=payload)