Snowflake (Legado)

​

Visão geral

• Exportação: Envie automaticamente dados de eventos de mensagens (push, e-mail, SMS, in-app) do OneSignal para o Snowflake para análise e relatórios.
• Importação: Sincronize eventos personalizados de usuários dos seus conjuntos de dados do Snowflake para o OneSignal para acionar Jornadas automatizadas e mensagens personalizadas.

​

Exportar eventos do OneSignal para o Snowflake

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

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

​

1. Inscreva-se

​

2. Forneça informações da conta

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

​

3. Aceite o compartilhamento de dados no Snowflake

​

Eventos e propriedades

​

Dados de eventos de mensagens

​

Tipos de eventos de mensagens

​

Retenção de dados

​

Importar eventos do Snowflake

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

• Acesso a Event Streams para eventos de mensagem de saída (Limitações de plano e excedentes se aplicam)
• Acesso a Custom Events para sincronização de eventos de entrada (Limitações de plano e excedentes se aplicam)
• Plano de Conta Atualizado (não disponível em apps gratuitos)

• Conta Snowflake com acesso ao warehouse
• Dados de eventos armazenados em tabelas ou visualizações 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;

​

Mapeamento de dados de evento

​

Esquema de tabela de eventos de exemplo

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

​

Gerenciamento de custos do warehouse

• Use o tamanho de warehouse X-Small para otimização de custos
• Configure auto-suspend (60 segundos) e auto-resume
• Agende sincronizações durante horários de baixo uso
• Considere compartilhar o 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 os custos do warehouse
• A autenticação por 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 o tamanho de warehouse X-Small
• Configure auto-suspend agressivo (60 segundos)
• Agende sincronizações durante horários de baixo uso
• Use sincronizações horárias/diárias em vez de sincronização contínua