Snowflake

​

Descripción general

• Salida: Envía automáticamente datos de eventos de mensajería (push, correo electrónico, SMS, in-app) desde OneSignal a Snowflake para análisis y generación de informes.
• Entrada: Sincroniza eventos de usuario personalizados desde tus conjuntos de datos de Snowflake a OneSignal para activar Journeys automatizados y mensajería personalizada.

​

Configuración de salida

• Crear paneles e informes personalizados
• Rastrear tendencias de entrega y participación entre canales
• Combinar datos de OneSignal con otros datos comerciales para análisis

• Plan Professional de OneSignal (no disponible en aplicaciones gratuitas)
• Cuenta de Snowflake
• Rol SECURITYADMIN o ACCOUNTADMIN en Snowflake (para configuración)

​

1. Recopila los detalles de tu cuenta de Snowflake

• Host de Snowflake: La URL de tu cuenta en el formato <account_identifier>.snowflakecomputing.com
• Nombre de la base de datos: La base de datos donde OneSignal escribirá los datos de eventos
• Nombre del esquema: El esquema dentro de la base de datos para las tablas de OneSignal (esto será creado automáticamente por OneSignal)
• Nombre del almacén: El almacén a utilizar para operaciones de carga de datos

​

2. Ejecuta el script de configuración en Snowflake

begin;

   -- create variables for user / role / warehouse / database (needs to be uppercase for objects)
   set role_name = 'ONESIGNAL_ROLE';
   set user_name = 'ONESIGNAL_USER';
   set warehouse_name = 'ONESIGNAL_WAREHOUSE';
   set database_name = 'ONESIGNAL';

   -- change role to securityadmin for user / role steps
   use role securityadmin;

   -- create role for onesignal
   create role if not exists identifier($role_name);
   grant role identifier($role_name) to role SYSADMIN;

   -- create a user for onesignal
   create user if not exists identifier($user_name)
   default_role = $role_name
   default_warehouse = $warehouse_name;

   grant role identifier($role_name) to user identifier($user_name);

   -- set binary_input_format to BASE64
   ALTER USER identifier($user_name) SET BINARY_INPUT_FORMAT = 'BASE64';

   -- set timestamp_input_format to AUTO for the user
   ALTER USER identifier($user_name) SET TIMESTAMP_INPUT_FORMAT = 'AUTO';

   -- change role to sysadmin for warehouse / database steps
   use role sysadmin;

   -- create a warehouse for onesignal
   create warehouse if not exists identifier($warehouse_name)
   warehouse_size = xsmall
   warehouse_type = standard
   auto_suspend = 60
   auto_resume = true
   initially_suspended = true;

   -- create database for onesignal
   create database if not exists identifier($database_name);

   -- grant onesignal role access to warehouse
   grant USAGE
   on warehouse identifier($warehouse_name)
   to role identifier($role_name);

   -- grant onesignal access to database
   grant CREATE SCHEMA, MONITOR, USAGE
   on database identifier($database_name)
   to role identifier($role_name);

 commit;

​

3. Genera un par de claves para autenticación

openssl genrsa 2048 | openssl pkcs8 -topk8 -inform PEM -out rsa_key.p8 -nocrypt

openssl genrsa 2048 | openssl pkcs8 -topk8 -v2 aes256 -inform PEM -out rsa_key.p8

openssl rsa -in rsa_key.p8 -pubout -out rsa_key.pub

ALTER USER ONESIGNAL_USER SET RSA_PUBLIC_KEY='<YOUR_PUBLIC_KEY_CONTENT>';

​

4. Conecta OneSignal

​

5. Ver datos en Snowflake

-- View recent message events
SELECT *
FROM <your-database>.<your-schema>.message_events
ORDER BY _CREATED DESC
LIMIT 100;

​

Eventos y propiedades de mensajes

​

Tipos de eventos de mensajes

​

Esquema de datos de eventos

​

Notas

• Las sincronizaciones después de guardar/activar pueden tardar de 15 a 30 minutos adicionales en completarse.
• Desactivar aún puede resultar en una sincronización final después de la desactivación.
• Para garantizar una sincronización de datos eficiente, nuestro sistema crea y gestiona automáticamente conjuntos de datos de preparación. Estos conjuntos de datos, nombrados con un patrón como fivetran_{dos palabras aleatorias}_staging, almacenan temporalmente datos durante el procesamiento antes de que se integren en su esquema principal. Estos conjuntos de datos de preparación son esenciales para mantener un flujo de trabajo optimizado y no deben eliminarse, ya que se recrearán automáticamente.

​

Migración desde la versión heredada

​

Diferencias clave

​

Cambios de esquema

​

Cambios de nombre de columnas

​

Inferencia de tipos

WHERE EXTERNAL_ID = '12345'::VARCHAR

​

Migración de consultas

1. Actualiza las referencias a la base de datos heredada para apuntar a tu nueva base de datos de Snowflake
2. Ten en cuenta los cambios de nombre de columnas listados arriba
3. Añade conversión de tipos explícita donde sea necesario

CREATE VIEW your_schema.message_events_compat AS
SELECT
  *,
  EVENT_TIMESTAMP AS EVENT_IMPRESSION_TIMESTAMP,
  LANGUAGE AS SUBSCRIPTION_LANGUAGE,
  MESSAGE_CONTENTS AS MESSAGE_BODY
FROM ONESIGNAL_DB.ONESIGNAL_EVENTS_XXXXX.MESSAGE_EVENTS;

​

Configuración de entrada

• Activar Journeys basados en la actividad del usuario
• Personalizar mensajes basados en datos de comportamiento

• Acceso a flujos de eventos para eventos de mensajes salientes (Se aplican limitaciones del plan y sobrecargos)
• Acceso a eventos personalizados para sincronización de eventos entrantes (Se aplican limitaciones del plan y sobrecargos)
• Plan de cuenta actualizado (no disponible en aplicaciones gratuitas)

• Cuenta de Snowflake con acceso al almacén
• Datos de eventos almacenados en tablas o vistas de Snowflake
• Conectividad de red desde OneSignal a tu instancia de Snowflake
• Credenciales de usuario con los permisos apropiados

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

​

Mapeo de datos de eventos

​

Esquema de tabla de eventos de ejemplo

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

​

Configuración avanzada

​

Gestión de costos del almacén

• Usa tamaño de almacén X-Small para optimización de costos
• Configura suspensión automática (60 segundos) y reanudación automática
• Programa sincronizaciones durante horas de menor actividad
• Considera compartir el almacén con otros sistemas de procesamiento por lotes

​

Soporte de sincronizaciones en vivo

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

​

Seguridad de red

​

Limitaciones

• Las consultas analíticas complejas pueden afectar el rendimiento y los costos del almacén
• La autenticación por Usuario/Contraseña quedará obsoleta en noviembre de 2025
• La base de datos CENSUS está reservada solo para operaciones de OneSignal

​

Preguntas frecuentes

​

¿Qué método de autenticación debo usar?

​

¿Puedo usar un almacén existente?

​

¿Cómo puedo optimizar los costos?

• Usa tamaño de almacén X-Small
• Configura suspensión automática agresiva (60 segundos)
• Programa sincronizaciones durante horas de menor actividad
• Usa sincronizaciones por hora/diarias en lugar de sincronización continua