Skip to content

aws-redshift.md

Latest commit

 

History

History
61 lines (43 loc) · 1.82 KB

aws-redshift.md

File metadata and controls

61 lines (43 loc) · 1.82 KB
Raw
description Power your Aqueduct workflow with data from Redshift

AWS Redshift

Connecting to AWS Redshift

You will need the following information:

  • Name: A unique name for your connection. This is totally up to you!
  • Host: The hostname or IP address of your AWS Redshift installation.
  • Port: The port at which your AWS Redshift DB is accessible; by default, AWS Redshift uses port 5439.
  • Database: The name of the database you're connecting to; each AWS Redshift connection currently only supports a single database.
  • Username: The username of the account via which you're connecting to AWS Redshift.
  • Password: The password corresponding to the above username

UI

To connect Aqueduct to AWS Redshift, navigate to the Aqueduct resources page and click on the AWS Redshift icon. Enter the information above.

SDK

import aqueduct as aq
from aqueduct.resources.connect_config import RedshiftConfig

client = aq.Client(s)

conf = RedshiftConfig(
    username="<USERNAME>",
    password="<PASSWORD>",
    host="<HOSTNAME>",
    port="<PORT>"
    database="<DATABASE>",
)
client.connect_resource("my_redshift_resource", "Redshift", conf)

Using AWS Redshift

Once you've creating a AWS Redshift connection, you can access your data from the Aqueduct SDK.

Reading Data

import aqueduct as aq
client = aq.Client()
RESOURCE_NAME = 'aws_redshift'

db = client.resource(RESOURCE_NAME)
wines = db.sql('SELECT * FROM wine;')

Writing Data

Every relational database in Aqueduct supports two update modes: replace and append. The former deletes and replaces the existing table in your database, while the latter appends data to an existing table. If the table does not exist or has a mismatched schema, the operation will fail.

db.save(wines, "wines_2", "replace")