Query Service dans le notebook Jupyter

Adobe Experience Platform vous permet d’utiliser le langage de requête structuré (SQL) dans Data Science Workspace en intégrant Query Service dans JupyterLab en tant que fonctionnalité standard.

Ce tutoriel présente des exemples de requêtes SQL pour des cas d’utilisation courants afin d’explorer, de transformer et d’analyser les données Adobe Analytics.

Prise en main

Avant de commencer ce tutoriel, vous devez disposer des éléments suivants :

JupyterLab d’accès et Query Service access-jupyterlab-and-query-service

Interrogation de vos données query-your-data

Entrez les requêtes SQL suivantes dans des cellules de notebook distinctes. Exécutez une requête en sélectionnant dans sa cellule, puis en cliquant sur le bouton lecture. Les résultats des requêtes réussies ou les journaux d’erreurs sont affichés sous la cellule exécutée.

Lorsqu’un notebook est inactif pendant une période prolongée, la connexion entre le notebook et Query Service peut être rompue. Dans ce cas, redémarrez JupyterLab en sélectionnant le bouton Redémarrer situé dans le coin supérieur droit à côté du bouton d’alimentation.

Le noyau du notebook se réinitialise, mais les cellules restent, réexécutez toutes les cellules pour continuer là où vous en étiez.

Décompte horaire de visiteurs hourly-visitor-count

La requête suivante renvoie le décompte horaire de visiteurs pour une date spécifique :

Requête

%%read_sql hourly_visitor -c QS_CONNECTION
SELECT Substring(timestamp, 1, 10)                               AS Day,
       Substring(timestamp, 12, 2)                               AS Hour,
       Count(DISTINCT concat(enduserids._experience.aaid.id,
                             _experience.analytics.session.num)) AS Visit_Count
FROM   {target_table}
WHERE TIMESTAMP = to_timestamp('{target_year}-{target_month}-{target_day}')
GROUP  BY Day, Hour
ORDER  BY Hour;

Dans la requête ci-dessus, la date et l’heure de la clause WHERE sont définies sur la valeur de target_year. Incluez des variables dans les requêtes SQL en les insérant entre parenthèses ({}).

La première ligne de la requête contient la variable facultative hourly_visitor. Les résultats des requêtes seront stockés dans cette variable sous la forme d’un cadre de données pandas. Le stockage des résultats dans un cadre de données vous permet de visualiser ultérieurement les résultats de la requête à l’aide du package de Python souhaité. Exécutez le code Python suivant dans une nouvelle cellule pour générer un graphique à barres :

trace = go.Bar(
    x = hourly_visitor['Hour'],
    y = hourly_visitor['Visit_Count'],
    name = "Visitor Count"
)
layout = go.Layout(
    title = 'Visit Count by Hour of Day',
    width = 1200,
    height = 600,
    xaxis = dict(title = 'Hour of Day'),
    yaxis = dict(title = 'Count')
)
fig = go.Figure(data = [trace], layout = layout)
iplot(fig)

Décompte horaire de l’activité hourly-activity-count

La requête suivante renvoie le décompte horaire d’actions pour une date spécifique :

Requête

%%read_sql hourly_actions -d -c QS_CONNECTION
SELECT Substring(timestamp, 1, 10)                        AS Day,
       Substring(timestamp, 12, 2)                        AS Hour,
       Count(concat(enduserids._experience.aaid.id,
                    _experience.analytics.session.num,
                    _experience.analytics.session.depth)) AS Count
FROM   {target_table}
WHERE TIMESTAMP = to_timestamp('{target_year}-{target_month}-{target_day}')
GROUP  BY Day, Hour
ORDER  BY Hour;

L’exécution de la requête ci-dessus stockera les résultats dans hourly_actions en tant que cadre de données. Exécutez la fonction suivante dans une nouvelle cellule pour prévisualiser les résultats :

hourly_actions.head()

La requête ci-dessus peut être modifiée pour renvoyer le décompte horaire d’actions pour une période spécifique à l’aide d’opérateurs logiques dans la clause WHERE :

Requête

%%read_sql hourly_actions_date_range -d -c QS_CONNECTION
SELECT Substring(timestamp, 1, 10)                        AS Day,
       Substring(timestamp, 12, 2)                        AS Hour,
       Count(concat(enduserids._experience.aaid.id,
                    _experience.analytics.session.num,
                    _experience.analytics.session.depth)) AS Count
FROM   {target_table}
WHERE  timestamp >= TO_TIMESTAMP('2019-06-01 00', 'YYYY-MM-DD HH')
       AND timestamp <= TO_TIMESTAMP('2019-06-02 23', 'YYYY-MM-DD HH')
GROUP  BY Day, Hour
ORDER  BY Hour;

L’exécution de la requête modifiée stocke les résultats dans hourly_actions_date_range en tant que cadre de données. Exécutez la fonction suivante dans une nouvelle cellule pour prévisualiser les résultats :

hourly_actions_date_rage.head()

Décompte d’événements par visite number-of-events-per-visitor-session

La requête suivante renvoie le décompte d’événements par visite pour une date spécifique :

Requête

%%read_sql events_per_session -c QS_CONNECTION
SELECT concat(enduserids._experience.aaid.id,
              '-#',
              _experience.analytics.session.num) AS aaid_sess_key,
       Count(timestamp)                          AS Count
FROM   {target_table}
WHERE TIMESTAMP = to_timestamp('{target_year}-{target_month}-{target_day}')
GROUP BY aaid_sess_key
ORDER BY Count DESC;

Exécutez le code Python suivant pour générer un histogramme pour le nombre d’événements par session de visite :

data = [go.Histogram(x = events_per_session['Count'])]

layout = go.Layout(
    title = 'Histogram of Number of Events per Visit Session',
    xaxis = dict(title = 'Number of Events'),
    yaxis = dict(title = 'Count')
)

fig = go.Figure(data = data, layout = layout)
iplot(fig)

Pages les plus consultées pour un jour spécifique popular-pages-for-a-given-day

La requête suivante renvoie les dix pages les plus consultées pour une date spécifique :

Requête

%%read_sql popular_pages -c QS_CONNECTION
SELECT web.webpagedetails.name                 AS Page_Name,
       Sum(web.webpagedetails.pageviews.value) AS Page_Views
FROM   {target_table}
WHERE TIMESTAMP = to_timestamp('{target_year}-{target_month}-{target_day}')
GROUP  BY web.webpagedetails.name
ORDER  BY page_views DESC
LIMIT  10;

Utilisateurs actifs pour un jour spécifique active-users-for-a-given-day

La requête suivante renvoie les dix utilisateurs les plus actifs pour une date spécifique :

Requête

%%read_sql active_users -c QS_CONNECTION
SELECT enduserids._experience.aaid.id AS aaid,
       Count(timestamp)               AS Count
FROM   {target_table}
WHERE TIMESTAMP = to_timestamp('{target_year}-{target_month}-{target_day}')
GROUP  BY aaid
ORDER  BY Count DESC
LIMIT  10;

Villes actives par activité d’utilisateur active-cities-by-user-activity

La requête suivante renvoie les dix villes qui génèrent la majorité des activités d’utilisateur pour une date spécifique :

Requête

%%read_sql active_cities -c QS_CONNECTION
SELECT concat(placeContext.geo.stateProvince, ' - ', placeContext.geo.city) AS state_city,
       Count(timestamp)                                                     AS Count
FROM   {target_table}
WHERE TIMESTAMP = to_timestamp('{target_year}-{target_month}-{target_day}')
GROUP  BY state_city
ORDER  BY Count DESC
LIMIT  10;

Étapes suivantes

Ce tutoriel a présenté quelques exemples de cas d’utilisation de Query Service dans des notebooks Jupyter. Suivez le tutoriel Analyser vos données à l’aide des notebooks Jupyter pour découvrir la manière dont des opérations similaires sont exécutées à l’aide du SDK d’accès aux données.