snippets_py
Integration
New integration from credential
aws_redshift_client = yepcode.integration.aws_redshift("credential-slug")
New integration from plain authentication data
import boto3
session = boto3.Session(
aws_access_key_id="accessKeyId",
aws_secret_access_key="secretAccessKey",
region_name="region"
)
aws_redshift_client = session.client("redshift-data")
Execute Statement
Execute statement
response = aws_redshift_client.execute_statement(
ClusterIdentifier="cluster-name",
Database="db-name",
DbUser="db-user",
Sql="sql"
)
print(response.get("Id"))
Execute Statement with Parameters
Execute statement with parameters
sql = "select * from users where id = :id"
params = [{"name": "id", "value": "1"}]
response = aws_redshift_client.execute_statement(
ClusterIdentifier="cluster-name",
Database="db-name",
DbUser="db-user",
Sql=sql,
Parameters=params
)
print(response.get("Id"))
Describe Statement
Describe statement
response = aws_redshift_client.describe_statement(Id="statement-id")
print(response.get("Status"))