Snowflake

Visão geral da integração OneSignal Snowflake

​

Visão geral

• Exportar: Envie automaticamente dados de eventos de mensagens (push, email, SMS, in-app) do OneSignal para o Snowflake para análise e relatórios.
• Importar: Sincronize eventos personalizados de usuários dos seus datasets do Snowflake para o OneSignal para acionar Journeys automatizados e mensagens personalizadas.

​

Exportar eventos do OneSignal para o Snowflake

• Construir dashboards e relatórios personalizados
• Rastrear tendências de entrega e engajamento entre canais
• Combinar dados do OneSignal com outros dados de negócios para análise

• Plano Professional do OneSignal (não disponível em apps gratuitos).
• Conta Snowflake
• Certifique-se de que sua conta Snowflake tem as funções IMPORT SHARE e CREATE DATABASE.
  • Recomendamos usar a função ACCOUNTADMIN para aceitar o compartilhamento.

​

1. Inscrever-se

​

2. Fornecer Informações da Conta

Copiando identificador da conta Snowflake

• Email do OneSignal dando as boas-vindas ao programa
• Email do Snowflake notificando que o compartilhamento de dados está completo

Email de notificação de compartilhamento de dados do Snowflake

​

3. Aceitar compartilhamento de dados no Snowflake

Interface de compartilhamento privado do Snowflake

Diálogo de status de replicação de dados

Diálogo de configuração de banco de dados

Conclusão da configuração de compartilhamento de dados

​

Eventos e Propriedades

​

Dados de Eventos de Mensagens

​

Tipos de Eventos de Mensagens

​

Retenção de Dados

​

Importar eventos do Snowflake

• Acionar Journeys com base na atividade do usuário
• Personalizar mensagens com base em dados comportamentais

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

• Conta Snowflake com acesso a warehouse
• Dados de eventos armazenados em tabelas ou views do Snowflake
• Conectividade de rede do OneSignal para sua instância Snowflake
• Credenciais de usuário com permissões apropriadas

-- Create a role for the census user
CREATE ROLE CENSUS_ROLE;

-- Ensure the sysadmin role inherits any privileges the census role is granted
GRANT ROLE CENSUS_ROLE TO ROLE SYSADMIN;

-- Create a warehouse for the census role, optimizing for cost over performance
CREATE WAREHOUSE CENSUS_WAREHOUSE WITH
    WAREHOUSE_SIZE = XSMALL
    AUTO_SUSPEND = 60
    AUTO_RESUME = TRUE
    INITIALLY_SUSPENDED = FALSE;

GRANT USAGE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT OPERATE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT MONITOR ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;

-- Create the census user
CREATE USER CENSUS WITH
    DEFAULT_ROLE = CENSUS_ROLE
    DEFAULT_WAREHOUSE = CENSUS_WAREHOUSE
    PASSWORD = '<strong-unique-password>';

GRANT ROLE CENSUS_ROLE TO USER CENSUS;

-- Grant access to your event data (replace with your actual database/schema)
GRANT USAGE ON DATABASE "<your-database>" TO ROLE CENSUS_ROLE;
GRANT USAGE ON SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;

-- Create a private bookkeeping database
CREATE DATABASE "CENSUS";
GRANT ALL PRIVILEGES ON DATABASE "CENSUS" TO ROLE CENSUS_ROLE;

CREATE SCHEMA "CENSUS"."CENSUS";
GRANT ALL PRIVILEGES ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;
GRANT CREATE STAGE ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;

​

Event data mapping

​

Exemplo de Schema de Tabela de Eventos

-- Example Snowflake event table
CREATE TABLE analytics.user_events (
    event_id STRING,
    event_name STRING NOT NULL,
    user_id STRING NOT NULL,
    event_timestamp TIMESTAMP_TZ DEFAULT CURRENT_TIMESTAMP(),
    event_properties VARIANT,
    session_id STRING,
    device_type STRING
);

​

Modo de Consulta SQL

-- Example: Recent high-value events
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_properties
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, CURRENT_TIMESTAMP())
    AND event_properties:value::NUMBER > 100
ORDER BY event_timestamp DESC;

​

Configuração avançada

​

Gerenciando Custos de Warehouse

• Use tamanho de warehouse X-Small para otimização de custos
• Configure auto-suspend (60 segundos) e auto-resume
• Agende sincronizações durante horários fora de pico
• Considere compartilhar warehouse com outros sistemas de processamento em lote

​

Suporte a Sincronizações ao Vivo

ALTER TABLE "analytics"."user_events" SET CHANGE_TRACKING = TRUE;

​

Segurança de Rede

​

Limitações

• Consultas analíticas complexas podem impactar o desempenho e custos do warehouse
• Autenticação de Usuário/Senha será descontinuada em novembro de 2025
• O banco de dados CENSUS é reservado apenas para operações do OneSignal

​

Desconectar compartilhamento de dados com o OneSignal

​

FAQ

​

Qual método de autenticação devo usar?

​

Posso usar um warehouse existente?

​

Como posso otimizar custos?

• Use tamanho de warehouse X-Small
• Configure auto-suspend agressivo (60 segundos)
• Agende sincronizações durante horários fora de pico
• Use sincronizações horárias/diárias em vez de sincronização contínua