Starburst Galaxy

Visão geral

A integração OneSignal + Starburst Galaxy permite a sincronização de eventos personalizados do seu cluster Starburst Galaxy para o OneSignal para acionar campanhas de mensagens automatizadas e Journeys com base no comportamento do usuário. Starburst Galaxy é uma plataforma de análise em nuvem totalmente gerenciada baseada em Trino, projetada para consultas SQL rápidas em data lakes e warehouses em nuvem.

Requisitos

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)

Cluster Starburst Galaxy com acesso de rede
Credenciais de usuário com permissões apropriadas
Suporte a conexão TLS (integrado ao Galaxy)
Dados de eventos acessíveis através de catálogos Galaxy

Configuração

Obter detalhes de conexão JDBC do Galaxy

No seu console Starburst Galaxy, navegue até os detalhes de conexão do seu cluster.Exemplo de URL JDBC:

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

Extrair hostname para o OneSignal:

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

O OneSignal usa JDBC para se conectar ao Starburst Galaxy. Você só precisa da porção do hostname da URL JDBC do Galaxy.

Configurar conexão do Starburst Galaxy

In OneSignal, go to Data > Integrations and click Add Integration.Selecione Starburst Galaxy e forneça os seguintes detalhes de conexão:

Host: Nome do host do seu cluster Galaxy (da Etapa 1)
Username: Seu nome de usuário Galaxy
Password: Sua senha Galaxy
Port: 443 (padrão para Galaxy)

Configurar Advanced Sync Engine (Opcional)

Para desempenho aprimorado, configure um catálogo CENSUS dedicado no Galaxy:

Crie um catálogo chamado CENSUS contendo um schema chamado CENSUS
Certifique-se de que seu conector suporta:
- Operações CREATE TABLE e DROP TABLE
- Gravações de tabela (INSERT, DELETE, UPDATE)
- Declaração CREATE OR REPLACE TABLE
Conceda permissões completas no schema CENSUS.CENSUS ao seu usuário OneSignal

Configurações testadas incluem conectores MySQL, PostgreSQL, Snowflake, Iceberg e catálogos Starburst Galaxy.

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

Exemplo de Consulta de Eventos

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

Consultas de Data Lake em Nuvem

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

Opções de Sync Engine

Basic Sync Engine

Funciona com qualquer catálogo e conector Galaxy
Rastreamento de estado gerenciado pela infraestrutura do OneSignal
Configuração mais simples sem requisitos adicionais

Advanced Sync Engine

Desempenho aprimorado com rastreamento de estado local
Requer catálogo e schema CENSUS.CENSUS dedicados
Suporta conectores com operações de gravação de tabela
Recomendado para processamento de eventos em nuvem de alto volume

Conectores Suportados

O Advanced Sync Engine do OneSignal foi testado com:

Conector MySQL (modo leitura-escrita)
Conector PostgreSQL (modo leitura-escrita)
Conector Snowflake (modo leitura-escrita)
Conector Iceberg (com S3 e AWS Glue)
Catálogo Starburst Galaxy (armazenamento nativo Galaxy)

Recursos da Plataforma em Nuvem

Federação Multi-Nuvem

Consulte fontes de dados AWS, Azure e GCP
Combine dados de S3, Snowflake, BigQuery e Azure
Análise unificada de eventos entre provedores de nuvem

Infraestrutura Gerenciada

Clusters Trino totalmente gerenciados com auto-scaling
Recursos integrados de segurança e conformidade
Sem necessidade de gerenciamento de infraestrutura

Catálogos Nativos do Galaxy

Armazenamento nativo Galaxy de alto desempenho
Integração perfeita com ecossistema Galaxy
Otimizado para cargas de trabalho de análise em nuvem

Limitações

Conexão TLS obrigatória (integrada ao Galaxy)
Advanced Sync Engine requer suporte a CREATE OR REPLACE TABLE
Warehouse Writeback ainda não suportado (em breve)
Não é possível fornecer opções de tabela personalizadas na cláusula WITH

FAQ

Como obtenho o hostname do meu cluster Galaxy?

No seu console Starburst Galaxy, vá para os detalhes de conexão do seu cluster e copie a URL JDBC. Extraia apenas a porção do hostname (sem o prefixo jdbc:trino://) para uso no OneSignal.

Posso consultar múltiplas fontes de dados em nuvem?

Sim! As capacidades de consulta federada do Starburst Galaxy permitem que você combine dados de eventos de múltiplas fontes em nuvem (S3, Snowflake, BigQuery, etc.) em uma única consulta.

O Galaxy suporta auto-scaling para cargas de trabalho do OneSignal?

Sim, o Starburst Galaxy escala automaticamente clusters com base na carga de consultas, garantindo desempenho ideal para seu processamento de eventos do OneSignal sem intervenção manual.

Primeiros passos & configurações

Canais de mensagem

Jornadas

Público & eventos personalizados

Análises & Integrações

Privacidade & Segurança

Starburst Galaxy

Visão geral

Requisitos