Azure Synapse

​

Vue d’ensemble

​

Prérequis

• Accès aux Event Streams pour les événements de message sortants (Les limitations de forfait et les dépassements s’appliquent)
• Accès aux Événements personnalisés pour la synchronisation des événements entrants (Les limitations de forfait et les dépassements s’appliquent)
• Forfait de compte mis à jour (non disponible sur les applications gratuites)

​

Azure Synapse

• Espace de travail Azure Synapse avec accès au pool SQL
• Utilisateur de base de données avec les permissions appropriées
• Tables d’événements contenant des données comportementales structurées
• Accès pare-feu pour les adresses IP de OneSignal

​

Configuration

USE <your-database>;

-- Create census login with the ability to sign in with a password
CREATE LOGIN CENSUS WITH PASSWORD = '<strong-unique-password>';

-- Create user for the login
CREATE USER CENSUS FOR LOGIN CENSUS;

-- Give the census user the ability to connect to database
GRANT CONNECT TO CENSUS;

-- Give the census user the ability to read all tables
EXEC sp_addrolemember 'db_datareader', CENSUS;

-- Grant census user ability to read schema and data
-- Run this for each schema you intend OneSignal to access
GRANT SELECT, VIEW DEFINITION ON SCHEMA::<your-schema> TO CENSUS;

-- Example: Add firewall rule for OneSignal IP range
EXEC sp_set_firewall_rule
    N'OneSignal Access',
    'ONESIGNAL_IP_START',
    'ONESIGNAL_IP_END';

​

Mappage des données d’événement

​

Exemple de schéma de table d’événements

-- Example Azure Synapse event table
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);

​

Mode de requête SQL

-- Example: Recent high-value events
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;

​

Fonctionnalités spécifiques à Azure

​

Architecture distribuée

• Événements distribués par user_id pour des performances de requête optimales
• Index columnstore en cluster pour les charges de travail analytiques
• Traitement massivement parallèle (MPP) pour les données d’événements à grande échelle

​

Intégration avec l’écosystème Azure

• Connexion à Azure Data Factory pour des pipelines d’événements automatisés
• Intégration avec Azure Event Hubs pour le streaming d’événements en temps réel
• Utilisation d’Azure Active Directory pour l’authentification

​

Configuration réseau avancée

​

Limitations

• Basé sur le protocole de connexion du pilote JDBC SQL Server
• Nécessite des règles de pare-feu explicites pour les adresses IP de OneSignal
• Les requêtes complexes peuvent avoir un impact sur les performances et les coûts du pool SQL
• Les opérations JSON nécessitent une indexation soigneuse pour des performances optimales

​

FAQ

​

Puis-je me connecter à plusieurs schémas Azure Synapse ?

​

Comment configurer l’accès pare-feu pour OneSignal ?

​

Quelle est la différence entre l’intégration Azure Synapse et SQL Server ?