确保AWS Redshift集群中启用了query capture功能。如果启用了该功能,可以使用以下代码示例解决问题:
import boto3
client = boto3.client('redshift-data')
query = "SELECT * FROM table_name WHERE column_name = 'value'"
database = 'mydatabase'
s3_bucket = 'mybucket'
s3_path = 'path/to/data'
response = client.execute_statement(
Database=database,
Sql=query,
ResultConfiguration={
'OutputLocation': f's3://{s3_bucket}/{s3_path}',
'EncryptionConfiguration': {
'EncryptionOption': 'SSE_S3'
}
}
)