Starburst Enterprise

​

Aperçu

​

Exigences

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

​

Starburst Enterprise

• Cluster Starburst Enterprise avec accès réseau
• Identifiants utilisateur avec les autorisations appropriées
• Prise en charge de connexion TLS (requis par OneSignal)
• Données d’événements accessibles via les catalogues Starburst

​

Configuration

jdbc:trino://census-example-cluster.trino.galaxy.starburst.io:[email protected]/accountadmin

census-example-cluster.trino.galaxy.starburst.io

​

Mappage des données d’événement

​

Exemple de requête d’événements

-- Example: Recent high-value events across catalogs
SELECT
    event_name,
    user_id,
    event_timestamp,
    CAST(event_properties AS JSON) as event_properties
FROM catalog.schema.user_events
WHERE event_timestamp >= current_timestamp - INTERVAL '7' DAY
    AND JSON_EXTRACT_SCALAR(event_properties, '$.value') > '100'
ORDER BY event_timestamp DESC;

​

Requêtes de lac de données d’entreprise

-- Example: Federated query across enterprise data sources
SELECT
    'enterprise_activity' as event_name,
    u.user_id,
    current_timestamp as event_timestamp,
    JSON_FORMAT(JSON_OBJECT(
        'crm_interactions', c.interaction_count,
        'warehouse_orders', w.order_count,
        'lake_analytics', l.score_value
    )) as event_properties
FROM salesforce_catalog.users.accounts u
LEFT JOIN crm_catalog.interactions.summary c ON u.user_id = c.user_id
LEFT JOIN warehouse_catalog.orders.summary w ON u.user_id = w.user_id
LEFT JOIN datalake_catalog.analytics.scores l ON u.user_id = l.user_id
WHERE u.created_date >= current_date - INTERVAL '30' DAY;

​

Options du moteur de synchronisation

​

Moteur de synchronisation de base

• Fonctionne avec n’importe quel catalogue et connecteur Starburst
• Suivi de l’état géré par l’infrastructure OneSignal
• Configuration plus simple sans exigences supplémentaires

​

Moteur de synchronisation avancé

• Performances améliorées avec suivi d’état local
• Nécessite un catalogue et un schéma CENSUS.CENSUS dédiés
• Prend en charge les connecteurs avec opérations d’écriture de table
• Recommandé pour le traitement d’événements d’entreprise à haut volume

​

Connecteurs pris en charge

• Connecteur MySQL (mode lecture-écriture)
• Connecteur PostgreSQL (mode lecture-écriture)
• Connecteur Snowflake (mode lecture-écriture)
• Connecteur Iceberg (avec S3 et AWS Glue)
• Connecteur Starburst Delta Lake (avec catalogues AWS Glue)

​

Fonctionnalités d’entreprise

​

Fédération multisource

• Interrogez plusieurs sources de données d’entreprise en une seule synchronisation
• Combinez les données d’événements CRM, d’entrepôt et de lac de données
• Profils d’événements clients unifiés provenant de systèmes disparates

​

Sécurité et conformité

• Authentification et autorisation de niveau entreprise
• Prise en charge de la sécurité au niveau des lignes et du masquage de colonnes
• Journalisation d’audit pour le suivi de l’accès aux données

​

Limitations

• Connexion TLS requise (exigence de sécurité OneSignal)
• Le moteur de synchronisation avancé nécessite la prise en charge de CREATE OR REPLACE TABLE
• Warehouse Writeback pas encore pris en charge (prochainement)
• Impossible de fournir des options de table personnalisées dans la clause WITH

​

FAQ

​

Comment obtenir le nom d’hôte de mon Starburst Enterprise ?

​

Puis-je interroger plusieurs sources de données d’entreprise ?

​

Quelle version de Starburst prend en charge le moteur de synchronisation avancé ?