Ana içeriğe atla

​
Genel Bakış

OneSignal + Starburst Enterprise entegrasyonu, kullanıcı davranışına dayalı otomatik mesajlaşma kampanyalarını ve Journey’leri tetiklemek için Starburst Enterprise kümenizden OneSignal’e özel etkinliklerin senkronize edilmesini sağlar. Starburst Enterprise, birden fazla kaynak arasında kurumsal analitik ve veri gölü sorgulaması için tasarlanmış Trino’nun ticari bir dağıtımıdır.

​
Gereksinimler

​
Starburst Enterprise

  • Ağ erişimine sahip Starburst Enterprise kümesi
  • Uygun izinlere sahip Kullanıcı kimlik bilgileri
  • TLS bağlantı desteği (OneSignal tarafından gereklidir)
  • Starburst katalogları aracılığıyla erişilebilir Etkinlik verileri

​
Kurulum

1

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

İstediğiniz küme için JDBC URL’nizi almak için Starburst’un belgelerini izleyin.Ö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 Enterprise’a bağlanmak için JDBC kullanır. JDBC URL’sinin yalnızca hostname bölümüne ihtiyacınız vardır.
2

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

In OneSignal, go to Data > Integrations and click Add Integration.Starburst Enterprise’ı seçin ve aşağıdaki bağlantı ayrıntılarını sağlayın:
  • Host: Starburst küme hostname’iniz (1. Adımdan)
  • Username: Starburst kullanıcı adınız
  • Password: Starburst şifreniz
  • Port: 443 (varsayılan) veya özel portunuz
3

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

Gelişmiş performans için, özel bir CENSUS kataloğu kurun:
  1. CENSUS adlı bir şema içeren CENSUS adlı bir katalog oluşturun
  2. 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
  3. CENSUS.CENSUS şemasında OneSignal kullanıcınıza tam izinler verin
Test edilen yapılandırmalar MySQL, PostgreSQL, Snowflake, Iceberg ve Starburst Delta Lake bağlayıcılarını içerir.

​
Event data mapping

Map your to OneSignal’s custom events format:
OneSignal FieldDescriptionRequired
nameevent_nameEvent identifierYes
external_iduser_idUser identifierYes
timestampevent_timestampWhen event occurredNo
propertiesevent_dataNo

​
Örnek Etkinlik Sorgusu

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

​
Kurumsal Veri Gölü Sorguları

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

​
Sync Engine Seçenekleri

​
Basic Sync Engine

  • Herhangi bir Starburst 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 kurumsal 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 Delta Lake bağlayıcısı (AWS Glue kataloglarıyla)

​
Kurumsal Özellikler

​
Çok Kaynaklı Federasyon

  • Tek bir senkronizasyonda kurumsal veri kaynakları arasında sorgulama
  • CRM, ambar ve veri gölü etkinlik verilerini birleştirme
  • Farklı sistemlerden birleşik müşteri etkinlik profilleri

​
Güvenlik ve Uyumluluk

  • Kurumsal sınıf kimlik doğrulama ve yetkilendirme
  • Satır düzeyinde güvenlik ve sütun maskeleme desteği
  • Veri erişim takibi için denetim günlüğü

​
Sınırlamalar

  • TLS bağlantısı gereklidir (OneSignal güvenlik gereksinimi)
  • 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

​
Starburst Enterprise hostname’imi nasıl alabilirim?

JDBC URL’nizi almak için Starburst’un belgelerini izleyin, ardından OneSignal’de kullanmak için yalnızca hostname bölümünü (jdbc:trino:// öneki olmadan) çıkarın.

​
Birden fazla kurumsal veri kaynağını sorgulayabilir miyim?

Evet! Starburst Enterprise’ın federe sorgu yetenekleri, birden fazla kurumsal kaynaktan (Salesforce, SAP, Oracle vb.) etkinlik verilerini tek bir sorguda birleştirmenize olanak tanır.

​
Hangi Starburst sürümü Advanced Sync Engine’i destekler?

Advanced Sync Engine işlevselliği için gerekli olan CREATE OR REPLACE TABLE desteği için Starburst Enterprise sürüm notlarınızı kontrol edin.