Gestion des données Platform à l’aide de Python et SQLAlchemy

Découvrez comment utiliser SQLAlchemy pour une plus grande flexibilité dans la gestion de vos données Adobe Experience Platform. Pour ceux qui ne sont pas aussi familiers avec SQL, SQLAlchemy peut améliorer considérablement le temps de développement lors de l’utilisation de bases de données relationnelles. Ce document fournit des instructions et des exemples de connexion. SQLAlchemy à Query Service et commencez à utiliser Python pour interagir avec vos bases de données.

SQLAlchemy est un mappeur relationnel d’objet (ORM) et un Python Bibliothèque de code qui peut transférer des données stockées dans une base de données SQL vers Python objets. Vous pouvez ensuite effectuer des opérations CRUD sur les données contenues dans le lac de données Platform à l’aide de Python code. Cela supprime la nécessité de gérer les données à l’aide de PSQL uniquement.

Prise en main

Pour acquérir les informations d’identification nécessaires à la connexion de SQLAlchemy à Experience Platform, vous devez avoir accès à l’espace de travail Requêtes dans l’interface utilisateur de Platform. Contactez l’administrateur de votre organisation si vous n’avez pas actuellement accès à l’espace de travail Requêtes .

Query Service informations

Pour trouver vos informations d’identification, connectez-vous à l’interface utilisateur de Platform et sélectionnez Requêtes à partir du volet de navigation de gauche, puis Informations d’identification. Pour obtenir des instructions complètes sur la manière de trouver vos informations de connexion, veuillez lire le guide des informations d’identification.

Bien que le port 80 soit le port recommandé pour une connexion à Query Service, vous pouvez également utiliser le port 5432.

Une fois que vous avez accès à vos informations d’identification QS, ouvrez votre Python éditeur de choix.

Stocker les informations d’identification dans Python

Dans votre Python éditeur, importez urllib.parse.quote et enregistrez chaque variable d’identification en tant que paramètre. Le urllib.parse fournit une interface standard pour ventiler les chaînes URL en composants. La fonction de guillemet remplace les caractères spéciaux dans la chaîne de l’URL pour que les données puissent être utilisées en toute sécurité comme composants d’URL. Vous trouverez ci-dessous un exemple du code requis :

from urllib.parse import quote

host = "<YOUR_HOST>"

port = "<YOUR_PORT>"

dbname = "<YOUR_DATABASE>"

user = "<YOUR_USERNAME>"

password = quote('''
<YOUR_PASSWORD>
''')

Création d’une instance de moteur [#create-engine]

Une fois les variables créées, importez la variable create_engine et créez une chaîne pour compiler et formater vos informations d’identification Query Service dans SQLAlchemy. Le create_engine est ensuite utilisée pour construire une instance de moteur.

SSL doit être activé lors de l’accès à Platform à l’aide de clients tiers. Dans le cadre de votre moteur, utilisez la variable connect_args pour saisir des arguments de mot-clé supplémentaires. Il est recommandé de définir le mode SSL sur require. Voir Documentation sur les modes SSL pour plus d’informations sur les valeurs acceptées.

L’exemple ci-dessous illustre le Python code nécessaire pour initialiser un moteur et une chaîne de connexion.

from sqlalchemy import create_engine

db_string = "postgresql://{user}:{password}@{host}:{port}/{dbname}".format(
    user=user,
    password=password,
    host=host,
    port = port,
    dbname = dbname
)

engine = create_engine(db_string, connect_args={'sslmode':'require'})

Vous êtes maintenant prêt à interroger les données de Platform à l’aide de Python. L’exemple ci-dessous renvoie un tableau de noms de table Query Service.

from sqlalchemy import inspect
insp = inspect(engine)
print(insp.get_table_names())