Pular para o conteúdo principal

​
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

​
Starburst Galaxy

  • 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

1

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.
2

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)
3

Configurar Advanced Sync Engine (Opcional)

Para desempenho aprimorado, configure um catálogo CENSUS dedicado no Galaxy:
  1. Crie um catálogo chamado CENSUS contendo um schema chamado CENSUS
  2. 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
  3. 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 FieldDescriptionRequired
nameevent_nameEvent identifierYes
external_iduser_idUser identifierYes
timestampevent_timestampWhen event occurredNo
propertiesevent_dataNo

​
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.