Customer.io プライマリワークフロー

概要

Customer.io のプライマリメッセージングワークフローを実装します。ユーザーを特定し、イベントを追跡し、自動化されたキャンペーンをトリガーします。

前提条件

• Customer.io SDK が設定済みであること
• Customer.io ダッシュボードでキャンペーン/ワークフローが作成されていること
• ユーザーライフサイクルイベントについての理解

手順

ステップ 1: ユーザーライフサイクルイベントを定義する

// events/user-events.ts
export const USER_EVENTS = {
  // Onboarding
  SIGNED_UP: 'signed_up',
  EMAIL_VERIFIED: 'email_verified',
  PROFILE_COMPLETED: 'profile_completed',
  FIRST_LOGIN: 'first_login',

  // Engagement
  FEATURE_USED: 'feature_used',
  CONTENT_VIEWED: 'content_viewed',
  SEARCH_PERFORMED: 'search_performed',

  // Conversion
  TRIAL_STARTED: 'trial_started',
  SUBSCRIPTION_STARTED: 'subscription_started',
  UPGRADE_COMPLETED: 'upgrade_completed',
  PURCHASE_COMPLETED: 'purchase_completed',

  // Churn Risk
  INACTIVE_WARNING: 'inactive_warning',
  SUBSCRIPTION_CANCELLED: 'subscription_cancelled',
  ACCOUNT_DELETED: 'account_deleted',
} as const;

export type UserEvent = typeof USER_EVENTS[keyof typeof USER_EVENTS];

ステップ 2: イベント追跡サービスを実装する

// services/customerio-service.ts
import { TrackClient, RegionUS } from '@customerio/track';
import { USER_EVENTS, UserEvent } from '../events/user-events';

interface User {
  id: string;
  email: string;
  firstName?: string;
  lastName?: string;
  plan?: string;
}

export class CustomerIOService {
  private client: TrackClient;

  constructor() {
    this.client = new TrackClient(
      process.env.CUSTOMERIO_SITE_ID!,
      process.env.CUSTOMERIO_API_KEY!,
      { region: RegionUS }
    );
  }

  // ユーザーサインアップ時に呼び出される
  async onSignup(user: User): Promise<void> {
    await this.client.identify(user.id, {
      email: user.email,
      first_name: user.firstName,
      last_name: user.lastName,
      created_at: Math.floor(Date.now() / 1000),
      plan: 'free',
      onboarding_status: 'started'
    });

    await this.track(user.id, USER_EVENTS.SIGNED_UP, {
      signup_source: 'web',
      signup_date: new Date().toISOString()
    });
  }

  // メール認証時に呼び出される
  async onEmailVerified(userId: string): Promise<void> {
    await this.updateUser(userId, {
      email_verified: true,
      email_verified_at: Math.floor(Date.now() / 1000)
    });
    await this.track(userId, USER_EVENTS.EMAIL_VERIFIED);
  }

  // サブスクリプション変更時に呼び出される
  async onSubscriptionStarted(userId: string, plan: string): Promise<void> {
    await this.updateUser(userId, {
      plan,
      subscription_started_at: Math.floor(Date.now() / 1000)
    });
    await this.track(userId, USER_EVENTS.SUBSCRIPTION_STARTED, { plan });
  }

  // 汎用の追跡メソッド
  async track(userId: string, event: UserEvent, data?: Record<string, any>): Promise<void> {
    await this.client.track(userId, {
      name: event,
      data: {
        ...data,
        timestamp: new Date().toISOString()
      }
    });
  }

  // ユーザー属性を更新する
  async updateUser(userId: string, attributes: Record<string, any>): Promise<void> {
    await this.client.identify(userId, attributes);
  }
}

export const cioService = new CustomerIOService();

ステップ 3: アプリケーションと統合する

// routes/auth.ts
import { cioService } from '../services/customerio-service';

app.post('/signup', async (req, res) => {
  const user = await createUser(req.body);

  // Fire and forget - サインアップをアナリティクスでブロックしない
  cioService.onSignup({
    id: user.id,
    email: user.email,
    firstName: user.firstName,
    lastName: user.lastName
  }).catch(err => console.error('Customer.io error:', err));

  res.json({ user });
});

app.post('/verify-email', async (req, res) => {
  const userId = await verifyEmailToken(req.body.token);

  cioService.onEmailVerified(userId)
    .catch(err => console.error('Customer.io error:', err));

  res.json({ success: true });
});

ステップ 4: ダッシュボードキャンペーンを作成する

Customer.io ダッシュボードで:

1. キャンペーン > キャンペーン作成に移動
2. トリガーを選択: イベント「signed_up」
3. ワークフローステップを追加:
   • 1 日待機
   • ウェルカムメールを送信
   • 3 日待機
   • 分岐: email_verified = false の場合、リマインダーを送信
   • ナーチャーシーケンスを続行

出力

• ユーザーライフサイクルイベント定義
• Customer.io サービス統合
• アプリケーションルート統合
• キャンペーンワークフロートリガー

エラーハンドリング

エラー	原因	解決策
イベントがトリガーされない	イベント名が違う	ダッシュボードで正確なイベント名と一致させる
ユーザーが受け取らない	メール属性が欠落している	identify でメールが設定されていることを確認
重複送信	複数回イベントが発火	重複排除またはべき等性を使用

リソース

• Customer.io Campaigns
• Trigger Events

次のステップ

プライマリワークフローの実装後、高度な機能については customerio-core-feature に進んでください。