Pipedream

TwexAPI를 통해 트윗 검색, 프로필, 인기 트윗, HTTP 트리거, 승인된 게시물을 위한 Pipedream 워크플로 자동화를 구축합니다.

검색, 프로필, 인기 트윗, 승인된 게시물을 위한 Pipedream Twitter 통합을 구축합니다. TwexAPI는 모든 워크플로에 하나의 REST API와 하나의 API 키를 제공합니다.

에이전트 핸드오프에는 웹훅 트리거를, 반복 검색에는 스케줄 트리거를, 사용자 지정 정규화가 필요할 때는 인라인 코드 단계를 선택하세요.

Pipedream 자동화 패턴 선택

검색, 웹훅 핸드오프, 팔로워 보내기, 승인된 쓰기를 별도 워크플로로 분리하세요. 워크플로가 작을수록 오류와 속도 제한이 더 명확하게 드러납니다.

전제조건

• TwexAPI API 키
• Pipedream 계정
• 선택적 Slack, Google Sheets, Airtable 또는 데이터베이스 연결 계정
• https://api.twexapi.io/mcp에 연결된 선택적 MCP 지원 에이전트

서버리스 API 통합

모든 TwexAPI 요청은 https://api.twexapi.io에서 시작합니다. Authorization: Bearer 헤더로 API 키를 전송합니다. 키는 단계보내기나 로그가 아닌 Pipedream 환경 변수에 보관하세요.

export TWEXAPI_API_KEY="YOUR_API_KEY"

GET /balance를 첫 인증 확인으로 사용하세요. X 계정을 변경하지 않고 API 키를 검증합니다.

공유 요청 헬퍼

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

시작 작업

트윗 검색 코드 단계

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

웹훅 우선 흐름

1. Pipedream에서 HTTP 트리거를 생성합니다.
2. MCP 지원 에이전트에 TwexAPI 행을 수집하고 엄격한 JSON을 반환하도록 요청합니다.
3. JSON을 Pipedream 엔드포인트에 POST합니다.
4. 코드 단계에서 행을 정규화하고 중복을 제거합니다.

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

권장 MCP 에이전트 프롬프트:

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.

결과 핸드오프

오류 처리

다운스트림 행을 보내기 전에 각 상태를 라우팅합니다.

다운스트림 처리가 성공한 후에만 페이지 커서를 유지합니다.

레시피

트윗 검색 → Slack

1. 보고 주기에 맞춰 워크플로를 스케줄합니다.
2. POST /twitter/advanced_search/page를 호출합니다.
3. 참여 임계값으로 트윗을 필터링합니다.
4. 선택한 트윗 텍스트, 작성자, 링크를 Slack으로 보냅니다.

에이전트 핸드오프 → Google Sheets

1. HTTP 트리거가 MCP 핸드오프 JSON을 수신합니다.
2. 트윗 행을 정규화합니다.
3. tweet_id로 Sheets에 upsert합니다.

팔로워 페이지 → CRM

1. HTTP 또는 스케줄 단계가 POST /v3/twitter/users/followers를 호출합니다.
2. 팔로워 행을 정규화합니다.
3. CRM이 user_id로 upsert합니다.
4. 데이터 저장소에 next_cursor를 유지합니다.

테스트 체크리스트

• 트리거 본문이 유효한 JSON인지 확인합니다.
• tweet_id 또는 user_id를 중복 제거 키로 사용합니다.
• 스케줄 연속 실행을 위해 Pipedream 데이터 저장소에 next_cursor를 저장합니다.
• TWEXAPI_API_KEY는 환경 변수에만 보관합니다.
• 단계 출력에 Bearer 토큰을 기록하지 않습니다.

다음 단계

• Make
• Zapier
• n8n
• Agent MCP Handoff
• API Reference