Amazon Redshift

​

概要

​

要件

• Access to Event Streams for outbound message events (Plan limitations and overages apply)
• Access to Custom Events for inbound event syncing (Plan limitations and overages apply)
• Updated Account Plan (not available on free apps)

​

Amazon Redshift

• ネットワークアクセス権を持つRedshiftクラスタ
• 適切な権限を持つデータベースユーザー
• 構造化された行動データを含むイベントテーブル
• OneSignalからRedshiftクラスタへのネットワーク接続

​

セットアップ

-- 強力なパスワードを持つOneSignalユーザーを作成
CREATE USER CENSUS WITH PASSWORD '<強力で一意のパスワード>';

-- 同期状態用のプライベート簿記スキーマを作成（読み取り専用モードの場合はスキップ）
CREATE SCHEMA CENSUS;

-- 簿記スキーマへのフルアクセスを許可（読み取り専用モードの場合はスキップ）
GRANT ALL ON SCHEMA CENSUS TO CENSUS;

-- 簿記スキーマ内の既存オブジェクトへのアクセスを確保（読み取り専用モードの場合はスキップ）
GRANT ALL PRIVILEGES ON ALL TABLES IN SCHEMA CENSUS TO CENSUS;

-- スキーマアクセスを許可（イベントデータを持つ各スキーマごとに繰り返す）
GRANT USAGE ON SCHEMA "<your_schema>" TO CENSUS;

-- 既存テーブルへの読み取りアクセスを許可
GRANT SELECT ON ALL TABLES IN SCHEMA "<your_schema>" TO CENSUS;

-- 将来のテーブルへの読み取りアクセスを許可
ALTER DEFAULT PRIVILEGES IN SCHEMA "<your_schema>" GRANT SELECT ON TABLES TO CENSUS;

-- 関数への実行権限を許可
GRANT EXECUTE ON ALL FUNCTIONS IN SCHEMA "<your_schema>" TO CENSUS;
ALTER DEFAULT PRIVILEGES IN SCHEMA "<your_schema>" GRANT EXECUTE ON FUNCTIONS TO CENSUS;

​

Event data mapping

​

イベントテーブルスキーマの例

-- Redshiftイベントテーブルの例
CREATE TABLE analytics.user_events (
    event_id BIGINT IDENTITY(1,1),
    event_name VARCHAR(100) NOT NULL,
    user_id VARCHAR(255) NOT NULL,
    event_timestamp TIMESTAMP DEFAULT GETDATE(),
    event_data SUPER,
    session_id VARCHAR(255),
    created_at TIMESTAMP DEFAULT GETDATE()
)
DISTKEY(user_id)
SORTKEY(event_timestamp);

​

SQLクエリモード

-- 例：最近の高価値イベント
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_data
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, GETDATE())
    AND JSON_EXTRACT_PATH_TEXT(event_data, 'value')::NUMERIC > 100
ORDER BY event_timestamp DESC;

​

dbt統合

​

オプション1：きめ細かい権限

-- dbtモデル内
{{ config(
    post_hook="GRANT SELECT ON {{ this }} TO CENSUS"
) }}

​

オプション2：デフォルト権限（推奨）

-- Redshiftスーパーユーザーが実行する必要があります
ALTER DEFAULT PRIVILEGES FOR USER "<your_dbt_run_user>"
IN SCHEMA "<your_dbt_target_schema>"
GRANT SELECT ON TABLES TO CENSUS;

​

高度なネットワーク設定

​

SSHトンネルのセットアップ

1. SSHユーザーを作成：SSHホストで専用ユーザーをセットアップします
2. トンネルを設定：OneSignal統合設定で「Use SSH Tunnel」を有効にします
3. キーペアをインストール：OneSignalの公開鍵を~/.ssh/authorized_keysに追加します
4. 接続をテスト：トンネル接続を検証します

​

VPCデプロイメント

1. AWSコンソールでVPCサービスに移動します
2. S3サービス用のVPCエンドポイントを作成します
3. Redshiftサブネットと関連付けます
4. ルーティングテーブルを設定します

​

パフォーマンスの最適化

​

ディストリビューションキーとソートキー

-- ユーザー中心のクエリ用にuser_idで分散
CREATE TABLE analytics.user_events (
    -- 列
)
DISTKEY(user_id)
SORTKEY(event_timestamp, event_name);

​

カラムナストレージ

• 圧縮：Redshiftは自動的に列を圧縮します
• ゾーンマップ：ソートされたデータでクエリパフォーマンスを向上させます
• 列指向：イベントデータの分析クエリに効率的です

​

制限事項

• 複数のスキーマには個別の権限付与が必要です
• クロススキーマテーブルを参照するビューには追加の権限が必要です
• 複雑なストアドプロシージャアクセスには追加のセットアップが必要な場合があります
• VPCデプロイメントにはS3 VPCエンドポイント設定が必要です

​

FAQ

​

OneSignalは大規模なイベントデータセットをどのように処理しますか？

​

読み取り専用モードを使用できますか？

​

dbt互換性についてはどうですか？