Pular para o conteúdo principal

​
Visão geral

A integração OneSignal + Starburst Enterprise permite a sincronização de eventos personalizados do seu cluster Starburst Enterprise para o OneSignal para acionar campanhas de mensagens automatizadas e Journeys com base no comportamento do usuário. Starburst Enterprise é uma distribuição comercial do Trino projetada para análises empresariais e consulta de data lake entre múltiplas fontes.

​
Requisitos

​
Starburst Enterprise

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

​
Configuração

1

Obter detalhes de conexão JDBC

Siga a documentação do Starburst para obter sua URL JDBC para o cluster desejado.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 Enterprise. Você só precisa da porção do hostname da URL JDBC.
2

Configurar conexão do Starburst Enterprise

In OneSignal, go to Data > Integrations and click Add Integration.Selecione Starburst Enterprise e forneça os seguintes detalhes de conexão:
  • Host: Nome do host do seu cluster Starburst (da Etapa 1)
  • Username: Seu nome de usuário Starburst
  • Password: Sua senha Starburst
  • Port: 443 (padrão) ou sua porta customizada
3

Configurar Advanced Sync Engine (Opcional)

Para desempenho aprimorado, configure um catálogo CENSUS dedicado:
  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 Starburst Delta Lake.

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

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

​
Opções de Sync Engine

​
Basic Sync Engine

  • Funciona com qualquer catálogo e conector Starburst
  • 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 empresariais 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)
  • Conector Starburst Delta Lake (com catálogos AWS Glue)

​
Recursos Empresariais

​
Federação Multi-Fonte

  • Consulte múltiplas fontes de dados empresariais em uma única sincronização
  • Combine dados de eventos de CRM, warehouse e data lake
  • Perfis de eventos de clientes unificados de sistemas díspares

​
Segurança e Conformidade

  • Autenticação e autorização de nível empresarial
  • Suporte a segurança em nível de linha e mascaramento de coluna
  • Registro de auditoria para rastreamento de acesso a dados

​
Limitações

  • Conexão TLS obrigatória (requisito de segurança do OneSignal)
  • 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 meu hostname do Starburst Enterprise?

Siga a documentação do Starburst para obter sua URL JDBC, depois extraia apenas a porção do hostname (sem o prefixo jdbc:trino://) para uso no OneSignal.

​
Posso consultar múltiplas fontes de dados empresariais?

Sim! As capacidades de consulta federada do Starburst Enterprise permitem que você combine dados de eventos de múltiplas fontes empresariais (Salesforce, SAP, Oracle, etc.) em uma única consulta.

​
Qual versão do Starburst suporta o Advanced Sync Engine?

Verifique as notas de lançamento do seu Starburst Enterprise para suporte a CREATE OR REPLACE TABLE, que é necessário para funcionalidade do Advanced Sync Engine.