はじめに
この記事では、DataDirectドライバを利用し、Windows上のPythonアプリケーションからAmazon RedshiftにODBCで簡単にデータ連携する方法を解説します。
Amazon Redshift用DataDirectドライバのインストール
１、Windows用DataDirect ODBC Driver for Amazon Redshiftをダウンロードします。
２、手順通りドライバをインストールします。
RedShift接続を設定する
１、ODBC Administratorより「追加」をクリックし、接続定義します。
ドライバは DataDirect 7.1 Amazon Redshift Wire Protocol を選択します。
２、設定ウィンドウで、以下のようにホスト名、ポート、データソースを入力します。
３、Test Connectをクリックし、ユーザー名とパスワードで正常に接続できるか確認します。
PythonからRedshiftに接続する
１、PythonからRedshiftにアクセスするには、pyodbcパッケージをインストールします。
以下のコマンドでインストールしてください。
pip install pyodbc
２、以下のようなPythonプログラムで、Redshiftデータにアクセスします。（接続設定を変更ください）
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)
３、上記のように接続文字列を定義するか、以下の接続文字列を使用しODBC Administratorでの接続設定を省略できます。
Driver={DataDirect 7.1 Amazon Redshift Wire Protocol}; HostName=ホスト名を設定ください; Database=DB名を設定ください; UID=ユーザIDを設定ください; PWD=パスワードを設定ください; Port=5439
非常に簡単ですね。
参考記事