Snowflake（レガシー）

概要

OneSignal + Snowflake統合は、2つの強力なデータパイプラインをサポートしています：

エクスポート：OneSignalからSnowflakeにメッセージングイベントデータ（プッシュ、メール、SMS、アプリ内）を自動的に送信し、分析とレポート作成を行います。
インポート：Snowflakeデータセットからカスタムユーザーイベントを OneSignalに同期して、自動Journeyとパーソナライズされたメッセージングをトリガーします。

これらの統合により、ユーザーエンゲージメントデータを完全に制御でき、高度な分析とリアルタイムの行動駆動型メッセージングが可能になります。

OneSignalイベントをSnowflakeにエクスポート

メッセージングのパフォーマンスとエンゲージメントイベント（送信、開封、クリックなど）をSnowflakeに送信して以下を実現します：

カスタムダッシュボードとレポートを構築
チャネル全体の配信とエンゲージメントのトレンドを追跡
OneSignalデータを他のビジネスデータと組み合わせて分析

要件

OneSignal Professionalプラン（無料アプリでは利用できません）
Snowflakeアカウント
SnowflakeアカウントにIMPORT SHAREとCREATE DATABASEのロールがあることを確認してください。
- 共有を承認するにはACCOUNTADMINロールの使用を推奨します。

セットアップ手順

1. サインアップ

Snowflake統合を有効化するには、Message Events DataのOneSignal Marketplaceリスティングからアクセスをリクエストする必要があります。その後、詳細情報を取得するために当社からチームに連絡します。

2. アカウント情報の提供

チームと連絡が取れたら、データを共有できるようにいくつかの詳細情報を提供していただく必要があります。Snowflake Account IDとSnowflake Organization IDが必要です。この情報を取得する最も簡単な方法は、「Copy account identifier」ボタンをクリックすることです（下図を参照）。

OneSignal Marketplaceリスティングを通じて当社と連絡を取る必要があります。ただし、アカウント情報の提供についてさらに質問がある場合は、snowflake-data-sharing@onesignal.comまでメールでお問い合わせください。

プログラムへの参加が承認されたら、以下の項目に注意してください：

OneSignalからプログラムへの参加を歓迎するメール
データ共有が完了したことを通知するSnowflakeからのメール

3. Snowflake内でデータ共有を承認

データ共有が完了したことを通知するSnowflakeからのメールを受信したら、Snowflakeアプリにログインしてデータ共有を承認できます。 Data → Private Sharingに移動すると、新しいPrivately Shared Listingが表示されます。Getをクリックすると、データがお客様のリージョンにレプリケートされ始めます。

注意：Getボタンが利用できず、Requestボタンが表示されている場合、共有を実行しようとしているロールの権限にCREATE DATABASEまたはIMPORT SHAREが含まれていません。ACCOUNTADMINロールに切り替えることをお勧めします。データのレプリケーションには時間がかかります。データが利用可能になると、Snowflakeから追加のメールが送信されます。次のようなダイアログが表示されます

データが使用可能になると、リスティングに新しいGetボタンが表示されます。Getボタンをクリックすると、新しいダイアログが表示されます

データベースとデータベースロールの名前を任意の名前に設定します。次にGetをクリックします

以上です！OneSignalからSnowflakeへのデータ同期が開始されました。同期の頻度は24時間に1回に設定されているため、初期データは翌日まで利用できない場合があります。

イベントとプロパティ

SnowflakeのMarketplaceで利用可能なデータの概要

メッセージイベントデータ

詳細については、Event Streamsを参照してください。ユーザーによって生成された各メッセージイベントには、以下のメタデータがレコードに添付されます。

カラム名	タイプ	説明	例
event_id	UUID	イベントを表す一意のID	`dc76df03-287c-403a-aabd-b2d4fe44e5c6`
event_kind	string	発生したイベントのタイプ。イベントの種類のリストはこちらで確認できます。	`message.email.opened`
event_impression_timestamp	unix_timestamp	OneSignalがイベントを処理した時刻	`1684951205`
subscription_id	UUID	デバイス/サブスクリプションを表す一意のID	`6e8b6978-75a4-4882-878c-2d15a78c2409`
subscription_language	string	このサブスクリプションの言語	`en`
subscription_timezone	integer	このサブスクリプションの指定されたタイムゾーン	`-25200`
subscription_device_type	string	このサブスクリプションが使用するデバイスのタイプ	`SMS`
onesignal_id	UUID	インプレッションを行ったユーザーのonesignal_id	`dc76df03-287c-403a-aabd-b2d4fe44e5c6`
external_id	string	インプレッションを行ったユーザーのexternal_id	`MyExternalId`
message_id	UUID	メッセージを表す一意のID	`dc76df03-287c-403a-aabd-b2d4fe44e5c6`
message_name	string	通知/メッセージの人間が読める形式のID	`Campaign 1`
message_title	string	通知/メッセージのタイトル。現在は英語のみ	`Bonus 50 coins when you play!`
message_body	string	メッセージの本文（短縮版）現在は英語のみ	`Play against your friends and earn an additional...`

メッセージイベントの種類

詳細については、Event Streamsを参照してください。メッセージイベントは、SnowflakeのMarketplaceで提供する最初のデータカテゴリです。追加のデータカテゴリのリクエストがある場合は、snowflake-data-sharing@onesignal.comまでお問い合わせください！

データ保持

Snowflake経由でOneSignalから共有されるデータは、30日間保持されます。この期間を超えてデータを保持するには、関連データを独自のテーブルにコピーすることをお勧めします。

Snowflakeからイベントをインポート

SnowflakeからOneSignalに行動イベントデータを送信して以下を実現します：

ユーザーアクティビティに基づいてJourneyをトリガー
行動データに基づいてメッセージングをパーソナライズ

要件

アウトバウンドメッセージイベント用のEvent Streamsへのアクセス（プランの制限と超過料金が適用されます）
インバウンドイベント同期用のCustom Eventsへのアクセス（プランの制限と超過料金が適用されます）
更新されたアカウントプラン（無料アプリでは利用できません）

ウェアハウスアクセス権を持つSnowflakeアカウント
Snowflakeテーブルまたはビューに保存されたイベントデータ
OneSignalからSnowflakeインスタンスへのネットワーク接続
適切な権限を持つユーザー認証情報

セットアップ手順

OneSignal専用のロールを作成

Snowflakeのベストプラクティスに従ってロール階層を作成します：

-- Create a role for the census user
CREATE ROLE CENSUS_ROLE;

-- Ensure the sysadmin role inherits any privileges the census role is granted
GRANT ROLE CENSUS_ROLE TO ROLE SYSADMIN;

専用ウェアハウスを作成

OneSignal操作用にコスト最適化されたウェアハウスを作成します：

-- Create a warehouse for the census role, optimizing for cost over performance
CREATE WAREHOUSE CENSUS_WAREHOUSE WITH
    WAREHOUSE_SIZE = XSMALL
    AUTO_SUSPEND = 60
    AUTO_RESUME = TRUE
    INITIALLY_SUSPENDED = FALSE;

GRANT USAGE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT OPERATE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT MONITOR ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;

ユーザーを作成して権限を付与

OneSignalユーザーを作成し、イベントデータへのアクセスを許可します：

-- Create the census user
CREATE USER CENSUS WITH
    DEFAULT_ROLE = CENSUS_ROLE
    DEFAULT_WAREHOUSE = CENSUS_WAREHOUSE
    PASSWORD = '<strong-unique-password>';

GRANT ROLE CENSUS_ROLE TO USER CENSUS;

-- Grant access to your event data (replace with your actual database/schema)
GRANT USAGE ON DATABASE "<your-database>" TO ROLE CENSUS_ROLE;
GRANT USAGE ON SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;

記帳データベースを作成（高度な同期エンジン）

OneSignalの同期状態管理用のプライベートデータベースを作成します：

-- Create a private bookkeeping database
CREATE DATABASE "CENSUS";
GRANT ALL PRIVILEGES ON DATABASE "CENSUS" TO ROLE CENSUS_ROLE;

CREATE SCHEMA "CENSUS"."CENSUS";
GRANT ALL PRIVILEGES ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;
GRANT CREATE STAGE ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;

基本同期エンジンまたは読み取り専用モードを使用する場合は、このステップをスキップしてください。

認証を設定

セキュリティを強化するために、キーペア認証（推奨）を設定します：

Snowflakeのドキュメントに従って公開鍵/秘密鍵のペアを生成します
Snowflakeユーザーに公開鍵を設定します
OneSignalの接続設定で秘密鍵を使用します

または、パスワード認証を使用することもできます（非推奨 - 2025年11月にブロックされます）。

OneSignalに接続

OneSignalで、Data > Integrationsに移動し、Add Integrationをクリックします。Snowflakeを選択し、以下の接続詳細を入力します：

アカウント名： Snowflakeアカウント識別子（例：abc123.us-east-1）
ウェアハウス： CENSUS_WAREHOUSE
ユーザー： CENSUS
データベース： イベントデータのデータベース名
スキーマ： イベントデータのスキーマ名
認証： キーペア（秘密鍵とオプションのパスフレーズを提供）

イベントデータマッピング

をOneSignalのカスタムイベント形式にマッピングします：

OneSignalフィールド	説明	必須
`name`	`event_name`	イベント識別子	はい
`external_id`	`user_id`	ユーザー識別子	はい
`timestamp`	`event_timestamp`	イベントが発生した時刻	いいえ
`properties`	`event_data`	いいえ

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

-- Example Snowflake event table
CREATE TABLE analytics.user_events (
    event_id STRING,
    event_name STRING NOT NULL,
    user_id STRING NOT NULL,
    event_timestamp TIMESTAMP_TZ DEFAULT CURRENT_TIMESTAMP(),
    event_properties VARIANT,
    session_id STRING,
    device_type STRING
);

SQLクエリモード

カスタムSQLクエリを記述してイベントデータを変換します：

-- Example: Recent high-value events
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_properties
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, CURRENT_TIMESTAMP())
    AND event_properties:value::NUMBER > 100
ORDER BY event_timestamp DESC;

高度な設定

ウェアハウスコストの管理

コスト最適化のためにX-Smallウェアハウスサイズを使用
自動サスペンド（60秒）と自動再開を設定
オフピーク時間に同期をスケジュール
他のバッチ処理システムとウェアハウスを共有することを検討

ライブ同期のサポート

リアルタイムイベント処理の場合、イベントテーブルで変更追跡を有効にします：

ALTER TABLE "analytics"."user_events" SET CHANGE_TRACKING = TRUE;

ネットワークセキュリティ

Snowflakeの許可IPネットワークポリシーを使用している場合は、OneSignalのIPアドレスを許可リストに追加してください。現在のIP範囲については、OneSignalサポートにお問い合わせください。

制限事項

複雑な分析クエリはウェアハウスのパフォーマンスとコストに影響を与える可能性があります
ユーザー/パスワード認証は2025年11月に非推奨になります
CENSUSデータベースはOneSignal操作専用に予約されています

OneSignalとのデータ共有を切断

OneSignalとのデータ共有を無効化するには、snowflake-data-sharing@onesignal.comまでメールでリクエストしてください。

FAQ

どの認証方法を使用すればよいですか？

キーペア認証を使用してください（推奨）。ユーザー/パスワード認証は、2025年11月からSnowflakeによってブロックされます。

既存のウェアハウスを使用できますか？

はい、dbtやFivetranなどの他のバッチ処理システムとウェアハウスを共有してコストを最適化できます。ウェアハウスにイベント処理のニーズに十分な容量があることを確認してください。

コストを最適化するにはどうすればよいですか？

X-Smallウェアハウスサイズを使用
アグレッシブな自動サスペンド（60秒）を設定
オフピーク時間に同期をスケジュール
連続同期の代わりに時間単位/日次同期を使用

​概要

​OneSignalイベントをSnowflakeにエクスポート

​1. サインアップ

​2. アカウント情報の提供

​3. Snowflake内でデータ共有を承認

​イベントとプロパティ

​メッセージイベントデータ

​メッセージイベントの種類

​データ保持

​Snowflakeからイベントをインポート

​イベントデータマッピング

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

​SQLクエリモード

​高度な設定

​ウェアハウスコストの管理

​ライブ同期のサポート

​ネットワークセキュリティ

​制限事項

​OneSignalとのデータ共有を切断

​FAQ

​どの認証方法を使用すればよいですか？

​既存のウェアハウスを使用できますか？

​コストを最適化するにはどうすればよいですか？

概要

OneSignalイベントをSnowflakeにエクスポート

1. サインアップ

2. アカウント情報の提供

3. Snowflake内でデータ共有を承認

イベントとプロパティ

メッセージイベントデータ

メッセージイベントの種類

データ保持

Snowflakeからイベントをインポート

イベントデータマッピング

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

SQLクエリモード

高度な設定

ウェアハウスコストの管理

ライブ同期のサポート

ネットワークセキュリティ

制限事項

OneSignalとのデータ共有を切断

FAQ

どの認証方法を使用すればよいですか？

既存のウェアハウスを使用できますか？

コストを最適化するにはどうすればよいですか？