Intégration de données depuis l'application Python sur Windows vers Amazon Redshift avec ODBC

introduction

Dans cet article, j'expliquerai comment lier facilement des données d'une application Python sous Windows à Amazon Redshift avec ODBC à l'aide du pilote DataDirect.

Installation du pilote DataDirect pour Amazon Redshift

1. Téléchargez pilote ODBC DataDirect pour Amazon Redshift .

2. Installez le pilote conformément à la procédure.

Configurer une connexion RedShift

1. Cliquez sur "Ajouter" depuis l'administrateur ODBC pour définir la connexion. Le pilote sélectionne DataDirect 7.1 Amazon Redshift Wire Protocol.

2. Dans la fenêtre des paramètres, entrez le nom d'hôte, le port et la source de données comme indiqué ci-dessous.

3. Cliquez sur Tester la connexion et vérifiez si vous pouvez vous connecter normalement avec votre nom d'utilisateur et votre mot de passe.

Connectez-vous à Redshift depuis Python

1. Pour accéder à Redshift à partir de Python, installez le package pyodbc. Veuillez installer avec la commande suivante.

pip install pyodbc

2. Accédez aux données Redshift avec le programme Python suivant. (Veuillez modifier les paramètres de connexion)

import pyodbc
 
conn = pyodbc.connect('DSN=Redshift;UID=awsuser;PWD=awsPassword')
 
cursor = conn.cursor()
 
## Create Tables
cursor.execute("CREATE TABLE Track ( TrackId INT NOT NULL, Name VARCHAR(200) NOT NULL, AlbumId INT, MediaTypeId INT NOT NULL, GenreId INT, Composer VARCHAR(220), Milliseconds INT NOT NULL, Bytes INT, UnitPrice NUMERIC(10,2) NOT NULL);")
 
cursor.execute("INSERT INTO Track (TrackId, Name, AlbumId, MediaTypeId, GenreId, Composer, Milliseconds, Bytes, UnitPrice) VALUES (1, 'For Those About To Rock (We Salute You)', 1, 1, 1, 'Angus Young, Malcolm Young, Brian Johnson', 343719, 11170334, 0.99);")
 
conn.commit()
 
##Access Data using SQL
cursor.execute("select * from Track")
while True:
    row = cursor.fetchone()
    if not row:
        break
    print(row)
 
##Access Data using SQL
cursor.execute("select * from Artist")
while True:
    row = cursor.fetchone()
    if not row:
        break
    print(row)

3. Vous pouvez définir la chaîne de connexion comme ci-dessus ou utiliser la chaîne de connexion suivante pour omettre les paramètres de connexion dans l'Administrateur ODBC.

Driver={DataDirect 7.1 Amazon Redshift Wire Protocol}; HostName=Veuillez définir le nom d'hôte; Database=Veuillez définir le nom de la base de données; UID=Veuillez définir l'ID utilisateur; PWD=Veuillez définir un mot de passe; Port=5439

C'est très facile.

Article de référence

Accès en temps réel à Amazon Redshift

Didacticiel DataDirect pour Redshift