Amazon Redshift

​

Présentation

​

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)

​

Amazon Redshift

• Cluster Redshift avec accès réseau
• Utilisateur de base de données avec les autorisations appropriées
• Tables d’événements contenant des données comportementales structurées
• Connectivité réseau de OneSignal vers votre cluster Redshift

​

Configuration

-- Créer un utilisateur OneSignal avec un mot de passe fort
CREATE USER CENSUS WITH PASSWORD '<strong-unique-password>';

-- Créer un schéma de comptabilité privé pour l'état de synchronisation (ignorer en mode lecture seule)
CREATE SCHEMA CENSUS;

-- Accorder un accès complet au schéma de comptabilité (ignorer en mode lecture seule)
GRANT ALL ON SCHEMA CENSUS TO CENSUS;

-- Assurer l'accès aux objets existants dans le schéma de comptabilité (ignorer en mode lecture seule)
GRANT ALL PRIVILEGES ON ALL TABLES IN SCHEMA CENSUS TO CENSUS;

-- Accorder l'accès au schéma (répéter pour chaque schéma avec des données d'événements)
GRANT USAGE ON SCHEMA "<your_schema>" TO CENSUS;

-- Accorder l'accès en lecture aux tables existantes
GRANT SELECT ON ALL TABLES IN SCHEMA "<your_schema>" TO CENSUS;

-- Accorder l'accès en lecture aux tables futures
ALTER DEFAULT PRIVILEGES IN SCHEMA "<your_schema>" GRANT SELECT ON TABLES TO CENSUS;

-- Accorder des autorisations d'exécution sur les fonctions
GRANT EXECUTE ON ALL FUNCTIONS IN SCHEMA "<your_schema>" TO CENSUS;
ALTER DEFAULT PRIVILEGES IN SCHEMA "<your_schema>" GRANT EXECUTE ON FUNCTIONS TO CENSUS;

​

Mappage des données d’événement

​

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

-- Exemple de table d'événements Redshift
CREATE TABLE analytics.user_events (
    event_id BIGINT IDENTITY(1,1),
    event_name VARCHAR(100) NOT NULL,
    user_id VARCHAR(255) NOT NULL,
    event_timestamp TIMESTAMP DEFAULT GETDATE(),
    event_data SUPER,
    session_id VARCHAR(255),
    created_at TIMESTAMP DEFAULT GETDATE()
)
DISTKEY(user_id)
SORTKEY(event_timestamp);

​

Mode de requête SQL

-- Exemple : Événements récents de grande valeur
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_data
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, GETDATE())
    AND JSON_EXTRACT_PATH_TEXT(event_data, 'value')::NUMERIC > 100
ORDER BY event_timestamp DESC;

​

Intégration dbt

​

Option 1 : Autorisations granulaires

-- Dans votre modèle dbt
{{ config(
    post_hook="GRANT SELECT ON {{ this }} TO CENSUS"
) }}

​

Option 2 : Privilèges par défaut (Recommandé)

-- Doit être exécuté par le super-utilisateur Redshift
ALTER DEFAULT PRIVILEGES FOR USER "<your_dbt_run_user>"
IN SCHEMA "<your_dbt_target_schema>"
GRANT SELECT ON TABLES TO CENSUS;

​

Configuration réseau avancée

​

Configuration du tunnel SSH

1. Créer un utilisateur SSH : Configurez un utilisateur dédié sur votre hôte SSH
2. Configurer le tunnel : Activez “Utiliser un tunnel SSH” dans les paramètres d’intégration OneSignal
3. Installer la paire de clés : Ajoutez la clé publique de OneSignal à ~/.ssh/authorized_keys
4. Tester la connexion : Vérifiez la connectivité du tunnel

​

Déploiement VPC

1. Accédez au service VPC dans la console AWS
2. Créez un point de terminaison VPC pour le service S3
3. Associez-le à votre sous-réseau Redshift
4. Configurez les tables de routage

​

Optimisation des performances

​

Clés de distribution et de tri

-- Distribuer par user_id pour les requêtes centrées sur l'utilisateur
CREATE TABLE analytics.user_events (
    -- colonnes
)
DISTKEY(user_id)
SORTKEY(event_timestamp, event_name);

​

Stockage en colonnes

• Compression : Redshift compresse automatiquement les colonnes
• Cartes de zones : Améliorez les performances des requêtes avec des données triées
• Orientation colonne : Efficace pour les requêtes analytiques sur les données d’événements

​

Limitations

• Les schémas multiples nécessitent des octrois d’autorisations séparés
• Les vues référençant des tables inter-schémas nécessitent des autorisations supplémentaires
• L’accès aux procédures stockées complexes peut nécessiter une configuration supplémentaire
• Les déploiements VPC nécessitent la configuration d’un point de terminaison VPC S3

​

FAQ

​

Comment OneSignal gère-t-il les ensembles de données d’événements volumineux ?

​

Puis-je utiliser le mode lecture seule ?

​

Qu’en est-il de la compatibilité dbt ?