IAMロールを使ってPythonを使ってRedshiftに接続

Question

私はsqlalchemyとpsycopg2を使ってpythonをredshiftに接続しています。

engine = create_engine('postgresql://user:password@hostname:port/database_name') 

redshiftに接続してIAMロールを使用する際にパスワードを使用しないでください。

Answer 1

AWS IAMユーザーはRedshiftデータベースユーザーとは異なります。 Redshiftはpostgresの（非常に遠い）相対関係ですが、まだパスワードなしの接続は許可されていません。

EDIT：

私の答えは、関連するコードスニペットのための他の回答を確認し、もはや適用されます。

Answer 2

AWSは、Redshiftクラスタにアクセスするための一時的な認証情報を要求する方法を提供します。 Boto3はget_cluster_credentialsを実装していますので、次のようなことができます。 instructions hereに従って、IAMユーザーと役割の設定を確認してください。

def db_connection(): 
    logger = logging.getLogger(__name__) 

    RS_PORT = 5439 
    RS_USER = 'myDbUser' 
    DATABASE = 'myDb' 
    CLUSTER_ID = 'myCluster' 
    RS_HOST = 'myClusterHostName' 

    client = boto3.client('redshift') 

    cluster_creds = client.get_cluster_credentials(DbUser=RS_USER, 
               DbName=DATABASE, 
              ClusterIdentifier=CLUSTER_ID, 
               AutoCreate=False) 

    try: 
     conn = psycopg2.connect(
     host=RS_HOST, 
     port=RS_PORT, 
     user=cluster_creds['DbUser'], 
     password=cluster_creds['DbPassword'], 
     database=DATABASE 
    ) 
     return conn 
    except psycopg2.Error: 
     logger.exception('Failed to open database connection.') 

Answer 3

彼らはJDBCドライバーのために行うようにAWSがpythonでIAM credsをのための便利なラッパーを提供していません。 GetClusterCredentialsエンドポイントを手動で呼び出し、返されたユーザー名とパスワードをcreate_engineに渡す必要があります。次のようになります。

def get_redshift_credentials(): 
    role_creds = get_role_credentials() 
    client = boto3.client(
     'redshift', 
     region_name=CLUSTER_REGION, 
     aws_access_key_id=role_creds['AccessKeyId'], 
     aws_secret_access_key=role_creds['SecretAccessKey'], 
     aws_session_token=role_creds['SessionToken'], 
    ) 
    response = client.get_cluster_credentials(
     DbUser=PGUSER, 
     ClusterIdentifier=CLUSTER_IDENTIFIER, 
    ) 
    return response 

creds = get_redshift_credentials() 
engine = create_engine('postgresql://{creds.DbUser}:{creds.DbPassword}@hostname:port/database_name'.format(creds))