Pipedream

Construisez une automatisation de workflow Pipedream pour la recherche de tweets, les profils, les tweets tendance, les triggers HTTP et les publications approuvées via TwexAPI.

Construisez une intégration Twitter Pipedream pour les recherches, profils, tweets tendance et publications approuvées. TwexAPI fournit une API REST et une clé API pour chaque workflow.

Choisissez un trigger webhook pour les handoffs agent, un trigger planifié pour les recherches récurrentes, ou des étapes de code inline lorsque vous avez besoin d’une normalisation personnalisée.

Choisir un modèle d’automatisation Pipedream

Séparez les recherches, handoffs webhook, exports d’abonnés et écritures approuvées dans des workflows distincts. Des workflows plus petits exposent les erreurs et limites de débit plus clairement.

Prérequis

• Clé API TwexAPI
• Compte Pipedream
• Comptes connectés Slack, Google Sheets, Airtable ou base de données optionnels
• Agent compatible MCP connecté à https://api.twexapi.io/mcp optionnel

Intégration API serverless

Commencez chaque requête TwexAPI à https://api.twexapi.io. Envoyez la clé API via le header Authorization: Bearer. Gardez les clés dans les variables d’environnement Pipedream, pas dans les exports d’étapes ou les logs.

export TWEXAPI_API_KEY="YOUR_API_KEY"

Utilisez GET /balance comme première vérification d’authentification. Elle vérifie la clé API sans modifier un compte X.

Helper de requête partagé

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();
    },
  },
});

Actions de démarrage

Étape code de recherche de tweets

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();
  },
});

Flux webhook-first

1. Créez un trigger HTTP dans Pipedream.
2. Demandez à un agent compatible MCP de collecter des lignes TwexAPI et retourner du JSON strict.
3. POSTez le JSON vers l’endpoint Pipedream.
4. Normalisez et dédupliquez les lignes dans une étape code.

Étape de normalisation JavaScript

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,
    }));
  },
});

Prompt agent MCP suggéré :

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.

Handoff de résultats

Gestion des erreurs

Routez chaque statut avant d’exporter les lignes en aval.

Persistez un curseur de page uniquement après succès du traitement en aval.

Recettes

Recherche de tweets vers Slack

1. Planifiez le workflow selon votre cadence de reporting.
2. Appelez POST /twitter/advanced_search/page.
3. Filtrez les tweets par seuil d’engagement.
4. Envoyez le texte, l’auteur et le lien des tweets sélectionnés à Slack.

Handoff agent vers Google Sheets

1. Le trigger HTTP reçoit le JSON de handoff MCP.
2. Normalisez les lignes de tweet.
3. Upsert dans Sheets par tweet_id.

Page d’abonnés vers CRM

1. L’étape HTTP ou planifiée appelle POST /v3/twitter/users/followers.
2. Normalisez les lignes d’abonnés.
3. Le CRM upsert par user_id.
4. Le data store conserve next_cursor.

Checklist de test

• Confirmez que le corps du trigger est du JSON valide.
• Utilisez tweet_id ou user_id comme clé de déduplication.
• Stockez next_cursor dans les data stores Pipedream pour la continuation planifiée.
• Gardez TWEXAPI_API_KEY uniquement dans les variables d’environnement.
• Ne jamais journaliser les tokens Bearer dans la sortie d’étape.

Prochaines étapes

• Make
• Zapier
• n8n
• Agent MCP Handoff
• Vue d’ensemble de l’API