Databricks

​

概要

• エクスポート：分析とレポート用にOneSignalメッセージイベントをDatabricksに送信します。
• インポート：Journeysをトリガーしキャンペーンをパーソナライズするために、DatabricksからOneSignalにカスタムイベントを送信します。

​

OneSignalメッセージイベントをDatabricksにエクスポート

• Professionalプラン以上
• カスタムイベントが有効（イベントインポート用）
• Databricksプラットフォーム：AWS、Azure、またはGCP
• Databricksプラン：Premium以上
• Databricks Unity Catalog（ガバナンスに推奨）
• クエリ用のDatabricks SQL Warehouse
• Delta Lakeイベントテーブル（カスタムイベントインポート用）

​

1. SQL Warehouseの詳細を収集

1

Databricksワークスペースにログイン

DatabricksワークスペースのSQL Warehousesに移動します。

2

Warehouseを選択

Warehouseを選択し、Connection detailsタブを開きます。

3

次の詳細を保存

• Server Hostname
• Port
• HTTP Path

​

2. サービスプリンシパルの作成

1

Service Principalsページに移動

Workspace Settings > Identity and Access > Service Principalsに移動します。

2

新しいサービスプリンシパルを追加

Add Service Principalをクリックし、次にAdd Newをクリックします。

3

サービスプリンシパルに名前を付ける

名前を付けます（例：onesignal-sync）。

​

3. シークレットの生成

1

作成されたプリンシパルをクリック

2

Secretsタブに移動

3

シークレットを生成

Generate Secretをクリックして安全に保存します。

シークレットは一度だけ表示されます。安全に保管してください。

​

4. 権限の割り当て

1

Catalogに移動してPermissionsタブを開く

2

Grantをクリック

3

サービスプリンシパルに次の権限を割り当てる

• USE CATALOG
• USE SCHEMA
• SELECT
• MODIFY
• CREATE SCHEMA
• CREATE TABLE

​

5. OneSignalを接続

1

統合をアクティブ化

OneSignalで、Data > Integrations > Databricksに移動します。

2

詳細を入力

• Server Hostname
• Port
• HTTP Path
• Catalog Name
• Schema Name
• Service Principal認証情報（ID + Secret）

3

統合を構成

• Sync Frequency： 15分ごとの頻度
• Dataset/Table Names： onesignal_events_<app-id>およびmessage_eventsとして事前設定（編集可能）
• Event Types： 同期するイベントを選択 - すべてまたは必要なものだけを選択

4

イベントを選択

Databricksカタログで受信したいイベントを選択します。

5

セットアップを完了

Saveをクリックして、成功確認を待ちます

​

6. Databricksでデータを表示

1. DatabricksでCatalogを開きます。
2. 同期が完了すると、構成されたスキーマが表示されます。
3. message_eventsテーブルにアクセスしてクエリします。

   

4. テーブルをクリックしてサンプルデータのプレビューを表示します。

   

​

メッセージイベントとプロパティ

​

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

​

イベントデータスキーマ

​

注意事項

• 保存/アクティブ化後の同期は、完了までにさらに15〜30分かかる場合があります。
• 非アクティブ化しても、非アクティブ化後に最終同期が1回行われる場合があります。
• 効率的なデータ同期を確保するために、システムは自動的にステージングデータセットを作成および管理します。これらのデータセットは、fivetran_{2つのランダムな単語}_stagingのようなパターンで命名され、メインスキーマに統合される前の処理中にデータを一時的に保存します。これらのステージングデータセットは、合理化されたワークフローを維持するために不可欠であり、削除しないでください。自動的に再作成されます。

​

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

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

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

• SQL Warehouseまたはコンピュートクラスターを持つDatabricksワークスペース
• 適切な権限を持つPersonal Access Token
• Delta Lake形式で行動データを含むイベントデータテーブル
• Unity Catalog（データガバナンスに推奨）

-- Unity Catalogが有効なワークスペースの場合
GRANT SELECT ON TABLE catalog.schema.event_table TO `onesignal@yourdomain.com`;

-- Hive metastoreテーブルの場合
GRANT SELECT ON TABLE database.event_table TO `onesignal@yourdomain.com`;

​

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

​

高度な構成

​

Unity Catalog統合

SELECT
  event_name,
  user_id,
  event_timestamp,
  to_json(
    named_struct(
      'product_id', product_id,
      'purchase_amount', purchase_amount,
      'category', category
    )
  ) as payload
FROM catalog.schema.user_events
WHERE event_timestamp >= current_timestamp() - INTERVAL 7 DAYS

​

Delta Lakeの最適化

• パーティショニング：より高速な時間ベースのクエリのために日付（event_date）でパーティション分割
• Z-Ordering：より良いフィルタリングのためにuser_idとevent_nameでZ-order
• Delta Lake機能：自動最適化のためにliquid clusteringを使用

​

ストリーミングイベント処理

• Structured Streaming：イベントが到着したときに処理
• Delta Live Tables：堅牢なイベント処理パイプラインを構築
• Auto Loader：新しいイベントファイルを継続的に取り込む

​

FAQ

​

同じコンテンツで異なるメッセージIDが表示されるのはなぜですか？

​

OneSignalはDatabricksからイベントをどのくらいの頻度で同期しますか？

​

イベント処理にDatabricksノートブックを使用できますか？

​

イベントクエリのコスト最適化はどうですか？