Starburst Galaxy

Genel Bakış

OneSignal + Starburst Galaxy entegrasyonu, kullanıcı davranışına dayalı otomatik mesajlaşma kampanyalarını ve Journey’leri tetiklemek için Starburst Galaxy kümenizden OneSignal’e özel etkinliklerin senkronize edilmesini sağlar. Starburst Galaxy, bulut veri gölleri ve ambarları arasında hızlı SQL sorguları için tasarlanmış, Trino tabanlı tamamen yönetilen bir bulut analitik platformudur.

Gereksinimler

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)

Ağ erişimine sahip Starburst Galaxy kümesi
Uygun izinlere sahip Kullanıcı kimlik bilgileri
TLS bağlantı desteği (Galaxy için yerleşik)
Galaxy katalogları aracılığıyla erişilebilir Etkinlik verileri

Kurulum

Galaxy JDBC bağlantı ayrıntılarını alın

Starburst Galaxy konsolunuzda, kümenizin bağlantı ayrıntılarına gidin.Örnek JDBC URL:

jdbc:trino://census-example-cluster.trino.galaxy.starburst.io:[email protected]/accountadmin

OneSignal için hostname’i çıkarın:

census-example-cluster.trino.galaxy.starburst.io

OneSignal, Starburst Galaxy’ye bağlanmak için JDBC kullanır. Galaxy’nin JDBC URL’sinden yalnızca hostname bölümüne ihtiyacınız vardır.

Starburst Galaxy bağlantısını yapılandırın

In OneSignal, go to Data > Integrations and click Add Integration.Starburst Galaxy’yi seçin ve aşağıdaki bağlantı ayrıntılarını sağlayın:

Host: Galaxy küme hostname’iniz (1. Adımdan)
Username: Galaxy kullanıcı adınız
Password: Galaxy şifreniz
Port: 443 (Galaxy için varsayılan)

Advanced Sync Engine'i Yapılandırın (İsteğe Bağlı)

Gelişmiş performans için, Galaxy’de özel bir CENSUS kataloğu kurun:

CENSUS adlı bir şema içeren CENSUS adlı bir katalog oluşturun
Bağlayıcınızın şunları desteklediğinden emin olun:
- CREATE TABLE ve DROP TABLE işlemleri
- Tablo yazmaları (INSERT, DELETE, UPDATE)
- CREATE OR REPLACE TABLE ifadesi
CENSUS.CENSUS şemasında OneSignal kullanıcınıza tam izinler verin

Test edilen yapılandırmalar MySQL, PostgreSQL, Snowflake, Iceberg ve Starburst Galaxy kataloglarını içerir.

Event data mapping

Map your to OneSignal’s custom events format:

OneSignal Field	Description	Required
`name`	`event_name`	Event identifier	Yes
`external_id`	`user_id`	User identifier	Yes
`timestamp`	`event_timestamp`	When event occurred	No
`properties`	`event_data`	No

Örnek Etkinlik Sorgusu

-- 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;

Bulut Veri Gölü Sorguları

-- Example: Federated query across cloud data sources
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;

Sync Engine Seçenekleri

Basic Sync Engine

Herhangi bir Galaxy kataloğu ve bağlayıcısıyla çalışır
OneSignal altyapısı tarafından yönetilen durum takibi
Ek gereksinim olmayan daha basit kurulum

Advanced Sync Engine

Yerel durum takibi ile gelişmiş performans
Özel CENSUS.CENSUS kataloğu ve şeması gerektirir
Tablo yazma işlemlerine sahip bağlayıcıları destekler
Yüksek hacimli bulut etkinlik işleme için önerilir

Desteklenen Bağlayıcılar

OneSignal’in Advanced Sync Engine şunlarla test edilmiştir:

MySQL bağlayıcısı (okuma-yazma modu)
PostgreSQL bağlayıcısı (okuma-yazma modu)
Snowflake bağlayıcısı (okuma-yazma modu)
Iceberg bağlayıcısı (S3 ve AWS Glue ile)
Starburst Galaxy kataloğu (yerel Galaxy depolaması)

Bulut Platformu Özellikleri

Çok Bulutlu Federasyon

AWS, Azure ve GCP veri kaynakları arasında sorgulama
S3, Snowflake, BigQuery ve Azure verilerini birleştirme
Bulut sağlayıcıları arasında birleşik etkinlik analitiği

Yönetilen Altyapı

Otomatik ölçeklendirme ile tamamen yönetilen Trino kümeleri
Yerleşik güvenlik ve uyumluluk özellikleri
Altyapı yönetimi gerekmez

Galaxy’ye Özgü Kataloglar

Yüksek performanslı yerel Galaxy depolaması
Galaxy ekosistemiyle sorunsuz entegrasyon
Bulut analitik iş yükleri için optimize edilmiş

Sınırlamalar

TLS bağlantısı gereklidir (Galaxy için yerleşik)
Advanced Sync Engine, CREATE OR REPLACE TABLE desteği gerektirir
Warehouse Writeback henüz desteklenmiyor (yakında)
WITH yan tümcesinde özel tablo seçenekleri sağlanamaz

SSS

Galaxy küme hostname’imi nasıl alabilirim?

Starburst Galaxy konsolunuzda, kümenizin bağlantı ayrıntılarına gidin ve JDBC URL’yi kopyalayın. OneSignal’de kullanmak için yalnızca hostname bölümünü (jdbc:trino:// öneki olmadan) çıkarın.

Birden fazla bulut veri kaynağını sorgulayabilir miyim?

Evet! Starburst Galaxy’nin federe sorgu yetenekleri, birden fazla bulut kaynağından (S3, Snowflake, BigQuery vb.) etkinlik verilerini tek bir sorguda birleştirmenize olanak tanır.

Galaxy, OneSignal iş yükleri için otomatik ölçeklendirmeyi destekliyor mu?

Evet, Starburst Galaxy, sorgu yüküne göre kümeleri otomatik olarak ölçeklendirir ve manuel müdahale olmadan OneSignal etkinlik işlemeniz için optimal performans sağlar.

İlk adımlar & ayarlar

Mesaj kanalları

Journey'ler

Hedeflenen & özel olaylar

Analitik ve Entegrasyonlar

Gizlilik & Güvenlik

Starburst Galaxy

Genel Bakış

Gereksinimler