Pipedream

Tweet araması, profiller, trend olan tweet'ler, HTTP tetikleyicileri ve onaylanmış gönderiler için TwexAPI aracılığıyla Pipedream iş akışı otomasyonu oluşturun.

Aramalar, profiller, trend olan tweet’ler ve onaylanmış gönderiler için bir Pipedream Twitter entegrasyonu oluşturun. TwexAPI her iş akışı için bir REST API ve bir API anahtarı sağlar.

Temsilci aktarımları için bir web kancası tetikleyicisi, yinelenen aramalar için bir zamanlama tetikleyicisi veya özel normalleştirmeye ihtiyaç duyduğunuzda satır içi kod adımları seçin.

Pipedream otomasyon modelini seçin

Aramaları, web kancası geçişlerini, takipçi dışa aktarmalarını ve onaylı yazma işlemlerini ayrı iş akışlarına bölün. Daha küçük iş akışları hataları ve hız sınırlarını daha net bir şekilde ortaya çıkarır.

Önkoşullar

• TwexAPI API anahtarı
• Pipedream hesabı
• Slack, Google E-Tablolar, Airtable veya bir veritabanı için isteğe bağlı bağlı hesaplar
• ’https://api.twexapi.io/mcp'ye bağlanan isteğe bağlı MCP özellikli aracı

Sunucusuz API entegrasyonu

Her TwexAPI isteğini “https://api.twexapi.io” adresinden başlatın. API anahtarını “Authorization: Bearer” başlığı aracılığıyla gönderin. Anahtarları adım dışa aktarmalarında veya günlüklerinde değil, Pipedream ortam değişkenlerinde tutun.

export TWEXAPI_API_KEY="YOUR_API_KEY"

İlk kimlik doğrulama kontrolü olarak `GET /balance’ı kullanın. Bir X hesabını değiştirmeden API anahtarını doğrular.

Paylaşılan istek yardımcısı

export default defineComponent({
  props: {
    twexapi: {
      type: "string",
      label: "TwexAPI API Key",
      secret: true,
    },
  },
  methods: {
    async twexapiRequest($, { method, path, body, params }) {
      const url = new URL(`https://api.twexapi.io${path}`);
      if (params) {
        Object.entries(params).forEach(([key, value]) => {
          if (value !== undefined && value !== null) {
            url.searchParams.set(key, String(value));
          }
        });
      }

      const response = await fetch(url, {
        method,
        headers: {
          Authorization: `Bearer ${this.twexapi}`,
          "Content-Type": "application/json",
        },
        body: body ? JSON.stringify(body) : undefined,
      });

      if (!response.ok) {
        throw new Error(`TwexAPI request failed with HTTP ${response.status}`);
      }

      return response.json();
    },
  },
});

Başlatıcı eylemleri

Tweet’lerde arama kodu adımı

export default defineComponent({
  async run({ steps, $ }) {
    const response = await fetch("https://api.twexapi.io/twitter/advanced_search/page", {
      method: "POST",
      headers: {
        Authorization: `Bearer ${process.env.TWEXAPI_API_KEY}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        searchTerms: ["AI agents lang:en"],
        sortBy: "Latest",
        nextCursor: "",
      }),
    });

    if (!response.ok) {
      throw new Error(`TwexAPI request failed with HTTP ${response.status}`);
    }

    return response.json();
  },
});

Webhook öncelikli akış

1. Pipedream’de bir HTTP tetikleyicisi oluşturun.
2. MCP özellikli bir aracıdan TwexAPI satırlarını toplamasını ve katı JSON döndürmesini isteyin.
3. POST the JSON to the Pipedream endpoint.
4. Bir kod adımında satırları normalleştirin ve tekilleştirin.

JavaScript normalleştirme adımı

export default defineComponent({
  async run({ steps }) {
    const payload = steps.trigger.event.body;

    return (payload.tweets || []).map((tweet) => ({
      id: tweet.tweet_id || tweet.id,
      url: tweet.public_url ?? `https://x.com/i/web/status/${tweet.tweet_id || tweet.id}`,
      author: tweet.author_username,
      text: tweet.text || tweet.full_text,
      created_at: tweet.created_at,
      route_used: payload.route_used,
      next_cursor: payload.next_cursor,
    }));
  },
});

Önerilen MCP aracısı istemi:

Use Twexapi MCP to get quote tweets for tweet ID 1803006263529541838.
Return only JSON with route_used, source_tweet_id, has_more, next_cursor, and tweets.
Each tweet must include tweet_id, author_username, text, created_at, and public_url.
Do not call write endpoints.

Sonuç aktarımı

Hata işleme

Aşağı akış satırlarını dışa aktarmadan önce her durumu yönlendirin.

Yalnızca aşağı akış işlemi başarılı olduktan sonra sayfa imlecini sürdürün.

Tarifler

Slack’e gönderilen tweet’leri arayın

1. İş akışını raporlama ritminize göre planlayın.
2. ’POST /twitter/advanced_search/page’i arayın.
3. Tweetleri etkileşim eşiğine göre filtreleyin.
4. Seçilen tweet metnini, yazarını ve bağlantısını Slack’e gönderin.

Temsilcinin Google E-Tablolar’a aktarımı

1. HTTP tetikleyicisi MCP aktarım JSON’unu alır.
2. Tweet satırlarını normalleştirin.
3. tweet_id ile E-Tablolar’a ekleyin.

CRM’e takipçi sayfası

1. HTTP veya zamanlanmış adım, ’POST /v3/twitter/users/followers’ı çağırır.
2. Takipçi satırlarını normalleştirin.
3. CRM user_id ile yükselir.
4. Veri deposu “next_cursor”u korur.

Test kontrol listesi

• Tetikleyici gövdesinin geçerli JSON olduğunu doğrulayın.
• Tekilleştirme anahtarı olarak tweet_id veya user_id kullanın.
• Planlanmış devam için `sonraki_imleci’ Pipedream veri depolarında saklayın.
• ’TWEXAPI_API_KEY’i yalnızca ortam değişkenlerinde tutun.
• Bearer jetonlarını asla adım çıkışına kaydetmeyin.

Sonraki adımlar

• Yap
• Zapier
• n8n
• Ajan MCP Aktarımı
• API Referansı