メインコンテンツへスキップ

​
概要

OneSignal + Starburst Enterprise統合により、Starburst EnterpriseクラスタからOneSignalにカスタムイベントを同期して、ユーザー行動に基づいた自動化されたメッセージングキャンペーンとJourneysをトリガーできます。 Starburst Enterpriseは、複数のソースにわたるエンタープライズ分析とデータレイククエリ向けに設計された、Trinoの商用ディストリビューションです。

​
要件

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

​
Starburst Enterprise

  • ネットワークアクセスを持つStarburst Enterpriseクラスタ
  • 適切な権限を持つユーザー認証情報
  • TLS接続サポート（OneSignalの要件）
  • Starburstカタログを通じてアクセス可能なイベントデータ

​
セットアップ

1

JDBC接続の詳細を取得する

Starburstのドキュメントに従って、目的のクラスタのJDBC URLを取得します。JDBC URLの例：
jdbc:trino://census-example-cluster.trino.galaxy.starburst.io:[email protected]/accountadmin
OneSignal用のホスト名を抽出：
census-example-cluster.trino.galaxy.starburst.io
OneSignalはJDBCを使用してStarburst Enterpriseに接続します。JDBC URLのホスト名部分のみが必要です。
2

Starburst Enterprise接続を設定する

OneSignalで、Data > Integrationsに移動し、Add Integrationをクリックします。Starburst Enterpriseを選択し、以下の接続詳細を入力します：
  • Host： Starburstクラスタのホスト名（ステップ1から）
  • Username： Starburstのユーザー名
  • Password： Starburstのパスワード
  • Port： 443（デフォルト）またはカスタムポート
3

高度な同期エンジンを設定する（オプション）

パフォーマンスを向上させるために、専用のCENSUSカタログをセットアップします：
  1. CENSUS という名前のスキーマを含む CENSUS という名前のカタログを作成します
  2. コネクタが以下をサポートしていることを確認します：
    • CREATE TABLE および DROP TABLE 操作
    • テーブル書き込み（INSERT、DELETE、UPDATE）
    • CREATE OR REPLACE TABLE ステートメント
  3. OneSignalユーザーに CENSUS.CENSUS スキーマの完全な権限を付与します
テスト済みの構成には、MySQL、PostgreSQL、Snowflake、Iceberg、およびStarburst Delta Lakeコネクタが含まれます。

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

をOneSignalのカスタムイベント形式にマッピングします：
OneSignalフィールド説明必須
nameevent_nameイベント識別子はい
external_iduser_idユーザー識別子はい
timestampevent_timestampイベントが発生した時刻いいえ
propertiesevent_dataいいえ

​
イベントクエリの例

-- Example: Recent high-value events across catalogs
SELECT
    event_name,
    user_id,
    event_timestamp,
    CAST(event_properties AS JSON) as event_properties
FROM catalog.schema.user_events
WHERE event_timestamp >= current_timestamp - INTERVAL '7' DAY
    AND JSON_EXTRACT_SCALAR(event_properties, '$.value') > '100'
ORDER BY event_timestamp DESC;

​
エンタープライズデータレイククエリ

-- 例：エンタープライズデータソース全体のフェデレーテッドクエリ
SELECT
    'enterprise_activity' as event_name,
    u.user_id,
    current_timestamp as event_timestamp,
    JSON_FORMAT(JSON_OBJECT(
        'crm_interactions', c.interaction_count,
        'warehouse_orders', w.order_count,
        'lake_analytics', l.score_value
    )) as event_properties
FROM salesforce_catalog.users.accounts u
LEFT JOIN crm_catalog.interactions.summary c ON u.user_id = c.user_id
LEFT JOIN warehouse_catalog.orders.summary w ON u.user_id = w.user_id
LEFT JOIN datalake_catalog.analytics.scores l ON u.user_id = l.user_id
WHERE u.created_date >= current_date - INTERVAL '30' DAY;

​
同期エンジンオプション

​
基本同期エンジン

  • 任意のStarburstカタログとコネクタで動作します
  • OneSignalインフラストラクチャによって管理される状態追跡
  • 追加要件のないシンプルなセットアップ

​
高度な同期エンジン

  • ローカル状態追跡による強化されたパフォーマンス
  • 専用の CENSUS.CENSUS カタログとスキーマが必要
  • テーブル書き込み操作をサポートするコネクタに対応
  • 大量のエンタープライズイベント処理に推奨

​
サポートされているコネクタ

OneSignalの高度な同期エンジンは、以下でテスト済みです：
  • MySQLコネクタ（読み取り/書き込みモード）
  • PostgreSQLコネクタ（読み取り/書き込みモード）
  • Snowflakeコネクタ（読み取り/書き込みモード）
  • Icebergコネクタ（S3およびAWS Glue使用）
  • Starburst Delta Lakeコネクタ（AWS Glueカタログ使用）

​
エンタープライズ機能

​
マルチソースフェデレーション

  • 単一の同期でエンタープライズデータソース全体をクエリ
  • CRM、ウェアハウス、データレイクのイベントデータを組み合わせ
  • 異種システムからの統合された顧客イベントプロファイル

​
セキュリティとコンプライアンス

  • エンタープライズグレードの認証と承認
  • 行レベルセキュリティとカラムマスキングのサポート
  • データアクセス追跡のための監査ログ

​
制限事項

  • TLS接続が必要（OneSignalのセキュリティ要件）
  • 高度な同期エンジンには CREATE OR REPLACE TABLE サポートが必要
  • ウェアハウスライトバックはまだサポートされていません（近日公開予定）
  • WITH 句でカスタムテーブルオプションを提供できません

​
FAQ

​
Starburst Enterpriseのホスト名を取得するにはどうすればよいですか？

StarburstのドキュメントでJDBC URLを取得し、OneSignalで使用するために（jdbc:trino:// プレフィックスなしで）ホスト名部分のみを抽出します。

​
複数のエンタープライズデータソースをクエリできますか？

はい！Starburst Enterpriseのフェデレーテッドクエリ機能により、単一のクエリで複数のエンタープライズソース（Salesforce、SAP、Oracleなど）からのイベントデータを組み合わせることができます。

​
高度な同期エンジンをサポートするStarburstリリースはどれですか？

高度な同期エンジン機能に必要な CREATE OR REPLACE TABLE サポートについては、Starburst Enterpriseのリリースノートを確認してください。