Création de jeux de données dérivés avec SQL

Découvrez comment utiliser des requêtes SQL pour manipuler et transformer des données de jeux de données existants afin de créer un jeu de données dérivé activé pour Profile. Ce workflow fournit une méthode alternative efficace pour créer des jeux de données dérivés pour vos cas d’utilisation professionnels de profil client en temps réel.

Ce document décrit diverses extensions SQL pratiques qui génèrent un jeu de données dérivé à utiliser avec Real-time Customer Profile. Le workflow simplifie le processus que vous devrez normalement exécuter par le biais de divers appels d’API ou interactions de l’interface utilisateur de Platform.

En règle générale, la génération et la publication d’un jeu de données dérivé pour Real-Time Customer Profile implique les étapes suivantes :

Après avoir suivi les étapes mentionnées ci-dessus, vous êtes prêt à renseigner le jeu de données. Si vous avez activé le jeu de données pour profile, vous pouvez également créer des segments qui font référence au nouveau jeu de données et commencer à produire des informations.

Query Service vous permet d’effectuer toutes les actions répertoriées ci-dessus à l’aide de requêtes SQL. Cela implique d’apporter des modifications à vos jeux de données et à vos groupes de champs si nécessaire.

Créer un tableau avec une option pour l’activer pour le profil enable-dataset-for-profile

Utilisez une requête Create Table as Select (CTAS) pour créer un jeu de données, attribuer des types de données, définir une identité principale, créer un schéma et le marquer comme profil activé. L’exemple d’instruction SQL ci-dessous crée un jeu de données et le rend disponible pour Real-Time Customer Data Platform (Real-Time CDP). Votre requête SQL suit le format indiqué dans l’exemple ci-dessous :

CREATE TABLE <your_table_name> [IF NOT EXISTS] (fieldname <your_data_type> primary identity namespace <your_namespace>, [field_name2 <your_data_type>]) [WITH(LABEL='PROFILE')];

Les types de données pris en charge sont les suivants : booléen, date, date, date, heure, texte, flottant, bigint, entier, map, tableau et struct/row.

Le bloc de code SQl ci-dessous fournit des exemples pour définir les types de données struct/row, map et array . La ligne 1 présente la syntaxe des lignes. La ligne 2 présente la syntaxe du mappage, la ligne 3, la syntaxe du tableau.

ROW (Column_name <data_type> [, column name <data_type> ]*)
MAP <data_type, data_type>
ARRAY <data_type>

Vous pouvez également activer les jeux de données pour le profil via l’interface utilisateur de Platform. Pour plus d’informations sur le marquage d’un jeu de données comme activé pour le profil, voir la documentation d’activation d’un jeu de données pour Real-time Customer Profile.

Dans l’exemple de requête ci-dessous, le jeu de données decile_table est créé avec id comme colonne d’identité principale et a l’espace de noms IDFA. Il comporte également un champ nommé decile1Month du type de données de carte. La table créée (decile_table) est activée pour le profil.

CREATE TABLE decile_table (id text PRIMARY KEY NAMESPACE 'IDFA',
            decile1Month map<text, integer>) WITH (label='PROFILE');

Une fois la requête exécutée avec succès, l’identifiant du jeu de données est renvoyé à la console, comme illustré dans l’exemple ci-dessous.

Created Table DataSet Id
>
637fd84969ba291e62dba79f
(1 row)

Utilisez label='PROFILE' sur une commande CREATE TABLE pour créer un jeu de données activé par le profil. La fonctionnalité upsert est activée par défaut. La fonctionnalité upsert peut être écrasée à l’aide de la commande ALTER, comme illustré dans l’exemple ci-dessous.

ALTER TABLE <your_table_name> DROP label upsert;

Pour plus d’informations sur l’utilisation de la commande ALTER TABLE et label dans le cadre d’une requête CTAS, consultez la documentation sur la syntaxe SQl.

Constructions destinées à aider à la gestion de jeux de données dérivés via SQL

Les fonctionnalités décrites ci-dessous sont très utiles pour la gestion de jeux de données dérivés via SQL.

Modifier les jeux de données existants à activer pour le profil enable-existing-dataset-for-profile

La structure SQL ALTER TABLE peut être utilisée pour activer les jeux de données existants pour le profil. Pour ce faire, une balise activée pour le profil doit être ajoutée au schéma et au jeu de données correspondant.

ALTER TABLE your_decile_table ADD label 'PROFILE';

Ajout d’une identité principale à un jeu de données existant add-primary-identity

Marquez une colonne existante d’un jeu de données comme jeu d’identités principal. Sinon, une erreur se produit. Pour définir une identité principale à l’aide de SQL, utilisez le format de requête affiché ci-dessous.

ALTER TABLE <your_table_name> ADD CONSTRAINT primary identity NAMESPACE

Par exemple :

ALTER TABLE test1_dataset ADD CONSTRAINT PRIMARY KEY(id2) NAMESPACE 'IDFA';

Dans l’exemple fourni, id2 est une colonne existante dans test1_dataset.

Désactivation d’un jeu de données pour un profil disable-dataset-for-profile

Si vous souhaitez désactiver votre table pour les utilisateurs de profils, vous devez utiliser la commande DROP . Vous trouverez ci-dessous un exemple d’instruction SQL USES DROP.

ALTER TABLE table_name DROP LABEL 'PROFILE';

Par exemple :

ALTER TABLE decile_table DROP label 'PROFILE';

Cette instruction SQL fournit une méthode alternative efficace à l’utilisation d’un appel API. Pour plus d’informations, consultez la documentation sur la désactivation d’un jeu de données à utiliser avec Real-Time CDP à l’aide de l’API des jeux de données.

Autoriser la mise à jour et l’insertion de fonctionnalités pour votre jeu de données enable-upsert-functionality-for-dataset

La commande UPSERT permet d'insérer un nouvel enregistrement ou de mettre à jour des données existantes dans un tableau. Plus précisément, il permet de mettre à jour une ligne existante si une valeur spécifiée existe déjà dans un tableau, ou d’insérer une nouvelle ligne si la valeur spécifiée n’existe pas déjà.

Vous trouverez ci-dessous un exemple d’instruction qui utilise le format correct.

ALTER TABLE table_name ADD LABEL 'UPSERT';

Par exemple :

ALTER TABLE table_with_a_decile ADD label 'UPSERT';

Cette instruction SQL fournit une méthode alternative efficace à l’utilisation d’un appel API. Pour plus d’informations, consultez la documentation sur l’ activation d’un jeu de données à utiliser avec Real-Time CDP et UPSERT à l’aide de l’API des jeux de données.

Désactivation de la mise à jour et de l’insertion de fonctionnalités pour votre jeu de données disable-upsert-functionality-for-dataset

Cette commande désactive la possibilité de mettre à jour et d’insérer des lignes dans votre jeu de données.

Vous trouverez ci-dessous un exemple d’instruction qui utilise le format correct.

ALTER TABLE table_name DROP LABEL 'UPSERT';

Par exemple :

ALTER TABLE table_with_a_decile DROP label 'UPSERT';

Afficher les informations supplémentaires du tableau associées à chaque tableau show-labels-for-tables

Des métadonnées supplémentaires sont conservées pour les jeux de données activés pour les profils. Utilisez la commande SHOW TABLES pour afficher une colonne labels supplémentaire qui fournit des informations sur les libellés associés aux tableaux.

Vous trouverez ci-dessous un exemple de sortie de cette commande :

       name          |        dataSetId         |     dataSet    | description | labels
---------------------+--------------------------+----------------+-------------+----------
 luma_midvalues      | 5bac030c29bb8d12fa992e58 | Luma midValues |             | false
 luma_postvalues     | 5c86b896b3c162151785b43c | Luma midValues |             | false
 table_with_a_decile | 5c86b896b3c162151785b43c | Luma midValues |             | 'UPSERT', 'PROFILE'
(3 rows)

Vous pouvez voir dans l’exemple que table_with_a_decile a été activé pour le profil et appliqué avec des étiquettes telles que 'UPSERT', 'PROFILE' comme décrit précédemment.

Création d’un groupe de champs avec SQL

Il est désormais possible de créer des groupes de champs à l’aide de SQL. Il s’agit d’une alternative à l’utilisation de l’éditeur de schémas dans l’interface utilisateur de Platform ou à l’exécution d’un appel API au registre des schémas.

Vous trouverez ci-dessous un exemple d’instruction pour créer un groupe de champs.

CREATE FIELDGROUP <field_group_name> [IF NOT EXISTS]  (field_name <data_type> primary identity namespace <namespace>, [field_name_2 >data_type>]) [ WITH(LABEL='PROFILE') ];

Un exemple concret peut ressembler à celui illustré ci-dessous.

CREATE FIELDGROUP field_group_for_test123 (decile1Month map<text, integer>, decile3Month map<text, integer>, decile6Month map<text, integer>, decile9Month map<text, integer>, decile12Month map<text, integer>, decilelietime map<text, integer>) WITH (LABEL-'PROFILE');

L’exécution réussie de cette instruction renvoie l’identifiant de groupe de champs créé. Par exemple c731a1eafdfdecae1683c6dca197c66ed2c2b49ecd3a9525.

Pour plus d’informations sur les autres méthodes, consultez la documentation sur la création d’un groupe de champs dans l’éditeur de schémas ou sur l’utilisation de l’ API Schema Registry .

Déposer un groupe de champs

Il peut parfois être nécessaire de supprimer un groupe de champs du registre des schémas. Pour ce faire, exécutez la commande DROP FIELDGROUP avec l’identifiant du groupe de champs.

DROP FIELDGROUP [IF EXISTS] <your_field_group_id>;

Par exemple :

DROP FIELDGROUP field_group_for_test123;

Afficher tous les noms et identifiants des groupes de champs pour vos tableaux

La commande SHOW FIELDGROUPS renvoie une table contenant le nom, fieldgroupId et le propriétaire des tables.

Vous trouverez ci-dessous un exemple de sortie de cette commande :

       name                      |        fieldgroupId                             |     owner      |
---------------------------------+-------------------------------------------------+-----------------
 AEP Mobile Lifecycle Details    | _experience.aep-mobile-lifecycle-details        | Luma midValues |
 AEP Web SDK ExperienceEvent     | _experience.aep-web-sdk-experienceevent         | Luma midValues |
 AJO Classification Fields       | _experience.journeyOrchestration.classification | Luma midValues |
 AJO Entity Fields               | _experience.customerJourneyManagement.entities  | Luma midValues |
(4 rows)

Étapes suivantes

Après avoir lu ce document, vous comprenez mieux comment utiliser SQL pour créer un profil et un jeu de données activé pour l’insertion en fonction de jeux de données dérivés. Vous êtes maintenant prêt à utiliser ce jeu de données avec des workflows d’ingestion par lots pour mettre à jour vos données de profil. Pour en savoir plus sur l’ingestion de données dans Adobe Experience Platform, commencez par lire la présentation de l’ingestion des données.