Starburst Galaxy

概要

OneSignal + Starburst Galaxy統合により、Starburst GalaxyクラスタからOneSignalにカスタムイベントを同期して、ユーザー行動に基づいた自動化されたメッセージングキャンペーンとJourneysをトリガーできます。 Starburst Galaxyは、Trinoをベースとしたフルマネージドクラウド分析プラットフォームで、クラウドデータレイクとウェアハウス全体での高速SQLクエリ向けに設計されています。

要件

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

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

セットアップ

Galaxy JDBC接続の詳細を取得する

Starburst Galaxyコンソールで、クラスタの接続詳細に移動します。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 Galaxyに接続します。GalaxyのJDBC URLからホスト名部分のみが必要です。

Starburst Galaxy接続を設定する

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

Host： Galaxyクラスタのホスト名（ステップ1から）
Username： Galaxyのユーザー名
Password： Galaxyのパスワード
Port： 443（Galaxyのデフォルト）

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

パフォーマンスを向上させるために、Galaxy内に専用のCENSUSカタログをセットアップします：

CENSUS という名前のスキーマを含む CENSUS という名前のカタログを作成します
コネクタが以下をサポートしていることを確認します：
- CREATE TABLE および DROP TABLE 操作
- テーブル書き込み（INSERT、DELETE、UPDATE）
- CREATE OR REPLACE TABLE ステートメント
OneSignalユーザーに CENSUS.CENSUS スキーマの完全な権限を付与します

テスト済みの構成には、MySQL、PostgreSQL、Snowflake、Iceberg、およびStarburst Galaxyカタログが含まれます。

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

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

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

イベントクエリの例

-- Example: Recent high-value events across Galaxy 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
    'cloud_activity' as event_name,
    u.user_id,
    current_timestamp as event_timestamp,
    JSON_FORMAT(JSON_OBJECT(
        's3_interactions', s.interaction_count,
        'snowflake_orders', sf.order_count,
        'bigquery_analytics', bq.score_value
    )) as event_properties
FROM s3_catalog.users.profiles u
LEFT JOIN s3_catalog.interactions.summary s ON u.user_id = s.user_id
LEFT JOIN snowflake_catalog.orders.summary sf ON u.user_id = sf.user_id
LEFT JOIN bigquery_catalog.analytics.scores bq ON u.user_id = bq.user_id
WHERE u.created_date >= current_date - INTERVAL '30' DAY;

同期エンジンオプション

基本同期エンジン

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

高度な同期エンジン

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

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

OneSignalの高度な同期エンジンは、以下でテスト済みです：

MySQLコネクタ（読み取り/書き込みモード）
PostgreSQLコネクタ（読み取り/書き込みモード）
Snowflakeコネクタ（読み取り/書き込みモード）
Icebergコネクタ（S3およびAWS Glue使用）
Starburst Galaxyカタログ（ネイティブGalaxyストレージ）

クラウドプラットフォーム機能

マルチクラウドフェデレーション

AWS、Azure、GCPデータソース全体をクエリ
S3、Snowflake、BigQuery、Azureデータを組み合わせ
クラウドプロバイダー全体での統合されたイベント分析

マネージドインフラストラクチャ

自動スケーリング機能を備えた完全マネージドTrinoクラスタ
組み込みのセキュリティとコンプライアンス機能
インフラストラクチャ管理は不要

Galaxyネイティブカタログ

高性能なネイティブGalaxyストレージ
Galaxyエコシステムとのシームレスな統合
クラウド分析ワークロードに最適化

制限事項

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

FAQ

Galaxyクラスタのホスト名を取得するにはどうすればよいですか？

Starburst Galaxyコンソールで、クラスタの接続詳細に移動し、JDBC URLをコピーします。OneSignalで使用するために（jdbc:trino:// プレフィックスなしで）ホスト名部分のみを抽出します。

複数のクラウドデータソースをクエリできますか？

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

GalaxyはOneSignalワークロードの自動スケーリングをサポートしていますか？

はい、Starburst Galaxyはクエリ負荷に基づいてクラスタを自動的にスケーリングし、手動操作なしでOneSignalイベント処理の最適なパフォーマンスを保証します。

はじめに & 設定

メッセージングチャネル

ジャーニー

オーディエンス & カスタムイベント

分析 & 統合

プライバシー & セキュリティ

Starburst Galaxy

概要

要件