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.
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 .
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.
Si vous utilisez des informations d’identification arrivant à expiration (comme illustré dans l’image ci-dessus) pour vous connecter à Query Service, la durée de session de votre connexion expire après la période définie dans les paramètres de votre organisation. Par défaut, cette période est de 24 heures. Consultez la documentation pour savoir comment connexion d’un client avec des informations d’identification non arrivant à expirationou comment modifier la durée de vie de la session pour vos informations d’identification arrivant à expiration ;.
Une fois que vous avez accès à vos informations d’identification QS, ouvrez votre Python éditeur de choix.
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 :
Utilisation PythonGuillemets triple pour saisir votre chaîne de mot de passe multi-lignes.
from urllib.parse import quote
host = "<YOUR_HOST>"
port = "<YOUR_PORT>"
dbname = "<YOUR_DATABASE>"
user = "<YOUR_USERNAME>"
password = quote('''
<YOUR_PASSWORD>
''')
Mot de passe que vous fournissez pour vous connecter SQLAlchemy pour Experience Platform expirera si vous utilisez des informations d’identification arrivant à expiration. Voir section informations d’identification pour plus d’informations.
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.
create_engine
renvoie une instance d’un moteur. Toutefois, elle n’ouvre pas la connexion à Query Service tant qu’une requête ne nécessite pas de connexion.
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'})
Mot de passe que vous fournissez pour vous connecter SQLAlchemy pour Experience Platform expirera si vous utilisez des informations d’identification arrivant à expiration. Voir section informations d’identification pour plus d’informations.
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())