Azure Synapse

​

Descripción general

​

Requisitos

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

​

Azure Synapse

• Espacio de trabajo de Azure Synapse con acceso a SQL pool
• Usuario de base de datos con permisos apropiados
• Tablas de eventos que contengan datos de comportamiento estructurados
• Acceso de firewall para direcciones IP de OneSignal

​

Configuración

USE <your-database>;

-- Crear inicio de sesión census con la capacidad de iniciar sesión con una contraseña
CREATE LOGIN CENSUS WITH PASSWORD = '<strong-unique-password>';

-- Crear usuario para el inicio de sesión
CREATE USER CENSUS FOR LOGIN CENSUS;

-- Dar al usuario census la capacidad de conectarse a la base de datos
GRANT CONNECT TO CENSUS;

-- Dar al usuario census la capacidad de leer todas las tablas
EXEC sp_addrolemember 'db_datareader', CENSUS;

-- Otorgar al usuario census capacidad de leer esquema y datos
-- Ejecute esto para cada esquema al que pretende que OneSignal acceda
GRANT SELECT, VIEW DEFINITION ON SCHEMA::<your-schema> TO CENSUS;

-- Ejemplo: Agregar regla de firewall para rango de IP de OneSignal
EXEC sp_set_firewall_rule
    N'OneSignal Access',
    'ONESIGNAL_IP_START',
    'ONESIGNAL_IP_END';

​

Event data mapping

​

Esquema de tabla de eventos de ejemplo

-- Ejemplo de tabla de eventos de Azure Synapse
CREATE TABLE analytics.user_events (
    event_id BIGINT IDENTITY(1,1) PRIMARY KEY,
    event_name NVARCHAR(100) NOT NULL,
    user_id NVARCHAR(255) NOT NULL,
    event_timestamp DATETIME2 DEFAULT GETUTCDATE(),
    event_data NVARCHAR(MAX),
    session_id NVARCHAR(255),
    device_type NVARCHAR(50)
)
WITH (DISTRIBUTION = HASH(user_id), CLUSTERED COLUMNSTORE INDEX);

​

Modo de consulta SQL

-- Ejemplo: Eventos recientes de alto valor
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_data
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, GETUTCDATE())
    AND JSON_VALUE(event_data, '$.value') > 100
ORDER BY event_timestamp DESC;

​

Características específicas de Azure

​

Arquitectura distribuida

• Eventos distribuidos por user_id para rendimiento óptimo de consultas
• Índices de columnstore agrupados para cargas de trabajo de análisis
• Procesamiento masivamente paralelo (MPP) para datos de eventos a gran escala

​

Integración con el ecosistema de Azure

• Conéctese a Azure Data Factory para pipelines de eventos automatizados
• Integre con Azure Event Hubs para streaming de eventos en tiempo real
• Aproveche Azure Active Directory para autenticación

​

Configuración de red avanzada

​

Limitaciones

• Basado en el protocolo de conexión del controlador JDBC de SQL Server
• Requiere reglas de firewall explícitas para direcciones IP de OneSignal
• Las consultas complejas pueden afectar el rendimiento y los costos del SQL pool
• Las operaciones JSON requieren indexación cuidadosa para un rendimiento óptimo

​

Preguntas frecuentes

​

¿Puedo conectarme a múltiples esquemas de Azure Synapse?

​

¿Cómo configuro el acceso de firewall para OneSignal?

​

¿Cuál es la diferencia entre la integración de Azure Synapse y SQL Server?